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

Packages that use IPartitionedTridentSpout

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

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

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

Modifier and Type	Class and Description
class	TransactionalTridentEventHubSpout Transactional Trident EventHub Spout

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

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

Modifier and Type	Class and Description
class	KafkaTridentSpoutTransactional

Uses of IPartitionedTridentSpout in org.apache.storm.kafka.trident

Classes in org.apache.storm.kafka.trident that implement IPartitionedTridentSpout

Modifier and Type	Class and Description
class	TransactionalTridentKafkaSpout Deprecated. storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client. If you need to migrate the committed offsets to the new spout, consider using the storm-kafka-migration tool.

Uses of IPartitionedTridentSpout in org.apache.storm.trident

Methods in org.apache.storm.trident with parameters of type IPartitionedTridentSpout

Modifier and Type	Method and Description
Stream	TridentTopology.newStream(String txId, IPartitionedTridentSpout spout)

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

Methods in org.apache.storm.trident.spout that return IPartitionedTridentSpout

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

Constructors in org.apache.storm.trident.spout with parameters of type IPartitionedTridentSpout

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