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>