Package storm.trident.spout

Interface Summary

Interface	Description
IBatchID
IBatchSpout
ICommitterTridentSpout<X>
ICommitterTridentSpout.Emitter
IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>	This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.
IOpaquePartitionedTridentSpout.Coordinator<Partitions>
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M>
IPartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,T>	This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
IPartitionedTridentSpout.Coordinator<Partitions>
IPartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,X>
ISpoutPartition
ITridentSpout<T>
ITridentSpout.BatchCoordinator<X>
ITridentSpout.Emitter<X>

Class Summary

Class	Description
BatchSpoutExecutor
BatchSpoutExecutor.EmptyCoordinator
OpaquePartitionedTridentSpoutExecutor
PartitionedTridentSpoutExecutor
RichSpoutBatchExecutor
RichSpoutBatchId
RichSpoutBatchIdSerializer
RichSpoutBatchTriggerer
TridentSpoutCoordinator
TridentSpoutExecutor