|
|||||||||
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 |