Uses of Interface
org.apache.storm.trident.spout.ISpoutPartition

Packages that use ISpoutPartition

Package	Description
org.apache.storm.eventhubs.trident
org.apache.storm.kafka.spout.trident
org.apache.storm.trident.spout

Uses of ISpoutPartition in org.apache.storm.eventhubs.trident

Classes in org.apache.storm.eventhubs.trident that implement ISpoutPartition

Modifier and Type	Class and Description
class	Partition Represents an EventHub partition.

Uses of ISpoutPartition in org.apache.storm.kafka.spout.trident

Classes in org.apache.storm.kafka.spout.trident that implement ISpoutPartition

Modifier and Type	Class and Description
class	KafkaTridentSpoutTopicPartition ISpoutPartition that wraps TopicPartition information.

Uses of ISpoutPartition in org.apache.storm.trident.spout

Classes in org.apache.storm.trident.spout with type parameters of type ISpoutPartition

Modifier and Type	Interface and Description
interface	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>

Methods in org.apache.storm.trident.spout that return types with arguments of type ISpoutPartition

Modifier and Type	Method and Description
IPartitionedTridentSpout<Object,ISpoutPartition,Object>	PartitionedTridentSpoutExecutor.getPartitionedSpout()

Constructor parameters in org.apache.storm.trident.spout with type arguments of type ISpoutPartition

Constructor and Description
OpaquePartitionedTridentSpoutExecutor(IOpaquePartitionedTridentSpout<Object,ISpoutPartition,Object> spout)
PartitionedTridentSpoutExecutor(IPartitionedTridentSpout<Object,ISpoutPartition,Object> spout)