Uses of Interface
org.apache.storm.trident.spout.ISpoutPartition
Packages that use ISpoutPartition
-
Uses of ISpoutPartition in org.apache.storm.kafka.spout.trident
Classes in org.apache.storm.kafka.spout.trident that implement ISpoutPartition -
Uses of ISpoutPartition in org.apache.storm.trident.spout
Classes in org.apache.storm.trident.spout with type parameters of type ISpoutPartitionModifier and TypeInterfaceDescriptioninterfaceIOpaquePartitionedTridentSpout<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.static interfaceIOpaquePartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition, M> interfaceIPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition, T> This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.static interfaceIPartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition, X> Methods in org.apache.storm.trident.spout that return types with arguments of type ISpoutPartitionConstructor parameters in org.apache.storm.trident.spout with type arguments of type ISpoutPartitionModifierConstructorDescriptionOpaquePartitionedTridentSpoutExecutor(IOpaquePartitionedTridentSpout<Object, ISpoutPartition, Object> spout)