|
|||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||
| Interface Summary | |
|---|---|
| IOpaquePartitionedTransactionalSpout<T> | This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id. |
| IOpaquePartitionedTransactionalSpout.Coordinator | |
| IOpaquePartitionedTransactionalSpout.Emitter<X> | |
| IPartitionedTransactionalSpout<T> | This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. |
| IPartitionedTransactionalSpout.Coordinator | |
| IPartitionedTransactionalSpout.Emitter<X> | |
| Class Summary | |
|---|---|
| OpaquePartitionedTransactionalSpoutExecutor | |
| PartitionedTransactionalSpoutExecutor | |
|
|||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||