org.apache.storm.trident.spout

Interface ITridentDataSource

All Superinterfaces:

Serializable

All Known Subinterfaces:

IBatchSpout, ICommitterTridentSpout<X>, IOpaquePartitionedTridentSpout<Partitions,Partition,M>, IPartitionedTridentSpout<Partitions,Partition,T>, ITridentSpout<T>

All Known Implementing Classes:

BatchSpoutExecutor, FeederBatchSpout, FeederCommitterBatchSpout, FixedBatchSpout, FixedBatchSpout, KafkaTridentSpoutOpaque, KafkaTridentSpoutTransactional, MetricGenBatchSpout, OpaquePartitionedTridentSpoutExecutor, OpaqueTridentEventHubSpout, OpaqueTridentKafkaSpout, PartitionedTridentSpoutExecutor, RandomNumberGeneratorSpout, RichSpoutBatchExecutor, TransactionalTridentEventHubSpout, TransactionalTridentKafkaSpout, TridentEsTopology.FixedBatchSpout, TridentHiveTopology.FixedBatchSpout, TridentJmsSpout, TridentSocketSpout

public interface ITridentDataSource
extends Serializable

ITridentDataSource marks all spouts that provide data into Trident.