executor

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.