package executor

  1. Public
  2. All

Type Members

  1. abstract class AsyncBase[I, O, S, D, RC] extends Serializable with OperationContainer[I, O, S, D, RC]

  2. class AtomicStateTransformer[T] extends AnyRef

  3. class FinalFlatMap[Event, Key, Value, S <: InputState[_], D, RC] extends AsyncBase[Event, (Int, Map[Key, Value]), S, D, RC]

  4. case class InputState[T](state: T) extends Product with Serializable

  5. class IntermediateFlatMap[T, U, S, D, RC] extends AsyncBase[T, U, S, D, RC]

  6. trait OperationContainer[Input, Output, State, WireFmt, RuntimeContext] extends AnyRef

  7. class Summer[Key, Value, Event, S, D, RC] extends AsyncBase[(Int, Map[Key, Value]), Event, InputState[S], D, RC]

    The SummerBolt takes two related options: CacheSize and MaxWaitingFutures.

Value Members

  1. object InflightTuples