Uses of Interface
org.apache.storm.trident.spout.ISpoutPartition
-
Uses of ISpoutPartition in org.apache.storm.kafka.spout.trident
-
Uses of ISpoutPartition in org.apache.storm.trident.spout
Modifier and TypeInterfaceDescriptioninterface
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.static interface
IOpaquePartitionedTridentSpout.Emitter<PartitionsT,
PartitionT extends ISpoutPartition, M> interface
IPartitionedTridentSpout<PartitionsT,
PartitionT extends ISpoutPartition, T> This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.static interface
IPartitionedTridentSpout.Emitter<PartitionsT,
PartitionT extends ISpoutPartition, X> ModifierConstructorDescriptionOpaquePartitionedTridentSpoutExecutor
(IOpaquePartitionedTridentSpout<Object, ISpoutPartition, Object> spout)