Package org.apache.storm.transactional.partitioned

Interface Summary

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

Class	Description
OpaquePartitionedTransactionalSpoutExecutor
PartitionedTransactionalSpoutExecutor