Package storm.trident.spout

Interface Summary
IBatchSpout  
ICommitterTridentSpout<X>  
ICommitterTridentSpout.Emitter  
IOpaquePartitionedTridentSpout<T> 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  
IOpaquePartitionedTridentSpout.Emitter<X>  
IPartitionedTridentSpout<T> This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
IPartitionedTridentSpout.Coordinator  
IPartitionedTridentSpout.Emitter<X>  
ITridentSpout<T>  
ITridentSpout.BatchCoordinator<X>  
ITridentSpout.Emitter<X>  
 

Class Summary
BatchSpoutExecutor  
BatchSpoutExecutor.EmptyCoordinator  
OpaquePartitionedTridentSpoutExecutor  
PartitionedTridentSpoutExecutor  
RichSpoutBatchExecutor  
RichSpoutBatchTriggerer  
TridentSpoutCoordinator  
TridentSpoutExecutor