Package org.apache.storm.trident.spout
package org.apache.storm.trident.spout
-
ClassDescriptionIOpaquePartitionedTridentSpout<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> ITridentDataSource marks all spouts that provide data into Trident.