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

Packages that use ITridentDataSource

Package	Description
org.apache.storm.elasticsearch.trident
org.apache.storm.eventhubs.trident
org.apache.storm.hive.trident
org.apache.storm.jms.trident
org.apache.storm.kafka.spout.trident
org.apache.storm.kafka.trident
org.apache.storm.opentsdb
org.apache.storm.sql.runtime
org.apache.storm.sql.runtime.datasource.socket.trident
org.apache.storm.starter.spout
org.apache.storm.trident
org.apache.storm.trident.spout
org.apache.storm.trident.testing

Uses of ITridentDataSource in org.apache.storm.elasticsearch.trident

Classes in org.apache.storm.elasticsearch.trident that implement ITridentDataSource

Modifier and Type	Class and Description
static class	TridentEsTopology.FixedBatchSpout

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

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

Modifier and Type	Class and Description
class	OpaqueTridentEventHubSpout Opaque Trident EventHubs Spout
class	TransactionalTridentEventHubSpout Transactional Trident EventHub Spout

Uses of ITridentDataSource in org.apache.storm.hive.trident

Classes in org.apache.storm.hive.trident that implement ITridentDataSource

Modifier and Type	Class and Description
static class	TridentHiveTopology.FixedBatchSpout

Uses of ITridentDataSource in org.apache.storm.jms.trident

Classes in org.apache.storm.jms.trident that implement ITridentDataSource

Modifier and Type	Class and Description
class	TridentJmsSpout Trident implementation of the JmsSpout

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

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

Modifier and Type	Class and Description
class	KafkaTridentSpoutOpaque<K,V>
class	KafkaTridentSpoutTransactional

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

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

Modifier and Type	Class and Description
class	OpaqueTridentKafkaSpout 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.
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.

Methods in org.apache.storm.kafka.trident with parameters of type ITridentDataSource

Modifier and Type	Method and Description
static StormTopology	TridentKafkaConsumerTopology.newTopology(ITridentDataSource tridentSpout) See TridentKafkaConsumerTopology.newTopology(LocalDRPC, ITridentDataSource)
static StormTopology	TridentKafkaConsumerTopology.newTopology(org.apache.storm.LocalDRPC drpc, ITridentDataSource tridentSpout)

Uses of ITridentDataSource in org.apache.storm.opentsdb

Classes in org.apache.storm.opentsdb that implement ITridentDataSource

Modifier and Type	Class and Description
class	MetricGenBatchSpout BatchSpout implementation for metrics generation.

Uses of ITridentDataSource in org.apache.storm.sql.runtime

Methods in org.apache.storm.sql.runtime that return ITridentDataSource

Modifier and Type	Method and Description
ITridentDataSource	ISqlTridentDataSource.getProducer() Provides instance of ITridentDataSource which can be used as producer in Trident.

Uses of ITridentDataSource in org.apache.storm.sql.runtime.datasource.socket.trident

Classes in org.apache.storm.sql.runtime.datasource.socket.trident that implement ITridentDataSource

Modifier and Type	Class and Description
class	TridentSocketSpout Trident Spout for Socket data.

Uses of ITridentDataSource in org.apache.storm.starter.spout

Classes in org.apache.storm.starter.spout that implement ITridentDataSource

Modifier and Type	Class and Description
class	RandomNumberGeneratorSpout This spout generates random whole numbers with given maxNumber value as maximum with the given fields.

Uses of ITridentDataSource in org.apache.storm.trident

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

Modifier and Type	Method and Description
Stream	TridentTopology.newStream(String txId, ITridentDataSource dataSource)

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

Subinterfaces of ITridentDataSource in org.apache.storm.trident.spout

Modifier and Type	Interface and Description
interface	IBatchSpout
interface	ICommitterTridentSpout<X>
interface	IOpaquePartitionedTridentSpout<Partitions,Partition 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.
interface	IPartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,T> This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
interface	ITridentSpout<T>

Classes in org.apache.storm.trident.spout that implement ITridentDataSource

Modifier and Type	Class and Description
class	BatchSpoutExecutor
class	OpaquePartitionedTridentSpoutExecutor
class	PartitionedTridentSpoutExecutor
class	RichSpoutBatchExecutor

Uses of ITridentDataSource in org.apache.storm.trident.testing

Classes in org.apache.storm.trident.testing that implement ITridentDataSource

Modifier and Type	Class and Description
class	FeederBatchSpout
class	FeederCommitterBatchSpout
class	FixedBatchSpout