com.twitter.summingbird.storm

Constants

object Constants extends OnlineDefaultConstants

These are the storm specific constants. Here we can override ones from online, or add more that are more Storm specific

Source
Constants.scala
Linear Supertypes
OnlineDefaultConstants, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Constants
  2. OnlineDefaultConstants
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. val AGG_BATCH: String

  7. val AGG_KEY: String

  8. val AGG_VALUE: String

  9. val DEFAULT_ACK_ON_ENTRY: AckOnEntry

  10. val DEFAULT_ASYNC_POOL_SIZE: AsyncPoolSize

    Definition Classes
    OnlineDefaultConstants
  11. val DEFAULT_FLUSH_FREQUENCY: FlushFrequency

    Definition Classes
    OnlineDefaultConstants
  12. val DEFAULT_FM_CACHE: CacheSize

    Definition Classes
    OnlineDefaultConstants
  13. val DEFAULT_FM_PARALLELISM: FlatMapParallelism

    Definition Classes
    OnlineDefaultConstants
  14. val DEFAULT_FM_PREFER_LOCAL_DEPENDENCY: PreferLocalDependency

  15. val DEFAULT_FM_STORM_METRICS: FlatMapStormMetrics

  16. val DEFAULT_MAX_EMIT_PER_EXECUTE: MaxEmitPerExecute

    Definition Classes
    OnlineDefaultConstants
  17. val DEFAULT_MAX_EXECUTE_PER_SEC: MaxExecutePerSecond

  18. val DEFAULT_MAX_FUTURE_WAIT_TIME: MaxFutureWaitTime

    Definition Classes
    OnlineDefaultConstants
  19. val DEFAULT_MAX_WAITING_FUTURES: MaxWaitingFutures

    Definition Classes
    OnlineDefaultConstants
  20. val DEFAULT_MONOID_IS_COMMUTATIVE: MonoidIsCommutative

    Definition Classes
    OnlineDefaultConstants
  21. val DEFAULT_ONLINE_EXCEPTION_HANDLER: OnlineExceptionHandler

    Definition Classes
    OnlineDefaultConstants
  22. val DEFAULT_ONLINE_SUCCESS_HANDLER: OnlineSuccessHandler

    Definition Classes
    OnlineDefaultConstants
  23. val DEFAULT_SOFT_MEMORY_FLUSH_PERCENT: SoftMemoryFlushPercent

    Definition Classes
    OnlineDefaultConstants
  24. val DEFAULT_SOURCE_PARALLELISM: SourceParallelism

    Definition Classes
    OnlineDefaultConstants
  25. val DEFAULT_SPOUT_STORM_METRICS: SpoutStormMetrics

  26. val DEFAULT_SUMMER_BATCH_MULTIPLIER: SummerBatchMultiplier

    Definition Classes
    OnlineDefaultConstants
  27. val DEFAULT_SUMMER_CACHE: CacheSize

    Definition Classes
    OnlineDefaultConstants
  28. val DEFAULT_SUMMER_PARALLELISM: SummerParallelism

    Definition Classes
    OnlineDefaultConstants
  29. val DEFAULT_SUMMER_STORM_METRICS: SummerStormMetrics

  30. val DEFAULT_USE_ASYNC_CACHE: UseAsyncCache

    Definition Classes
    OnlineDefaultConstants
  31. val DEFAULT_VALUE_COMBINER_CACHE_SIZE: ValueCombinerCacheSize

    Definition Classes
    OnlineDefaultConstants
  32. val GROUP_BY_SUM: String

  33. val RETURN_INFO: String

  34. val VALUE_FIELD: String

  35. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  36. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  38. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  39. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  40. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  41. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  42. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  43. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  44. final def notify(): Unit

    Definition Classes
    AnyRef
  45. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  46. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  47. def toString(): String

    Definition Classes
    AnyRef → Any
  48. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from OnlineDefaultConstants

Inherited from AnyRef

Inherited from Any

Ungrouped