Package org.apache.storm.trident.spout

Interface Summary

Interface	Description
IBatchID
IBatchSpout
ICommitterTridentSpout<X>
ICommitterTridentSpout.Emitter
IOpaquePartitionedTridentSpout<PartitionsT,PartitionT 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<PartitionsT>	Coordinator for batches.
IOpaquePartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,M>
IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>	This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
IPartitionedTridentSpout.Coordinator<PartitionsT>
IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,X>
ISpoutPartition
ITridentDataSource	ITridentDataSource marks all spouts that provide data into Trident.
ITridentSpout<T>
ITridentSpout.BatchCoordinator<X>
ITridentSpout.Emitter<X>

Class Summary

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