Uses of Package
org.apache.storm.trident.spout
-
Classes in org.apache.storm.trident.spout used by org.apache.storm.hdfs.trident Class Description IBatchSpout ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident. -
Classes in org.apache.storm.trident.spout used by org.apache.storm.hive.trident Class Description IBatchSpout ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident. -
Classes in org.apache.storm.trident.spout used by org.apache.storm.jms.trident Class Description ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident.ITridentSpout ITridentSpout.BatchCoordinator ITridentSpout.Emitter -
Classes in org.apache.storm.trident.spout used by org.apache.storm.kafka.spout.trident Class Description IOpaquePartitionedTridentSpout This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.IOpaquePartitionedTridentSpout.Coordinator Coordinator for batches.IOpaquePartitionedTridentSpout.Emitter IPartitionedTridentSpout This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.IPartitionedTridentSpout.Coordinator IPartitionedTridentSpout.Emitter ISpoutPartition ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident. -
Classes in org.apache.storm.trident.spout used by org.apache.storm.kafka.trident Class Description ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident. -
Classes in org.apache.storm.trident.spout used by org.apache.storm.starter.spout Class Description IBatchSpout ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident. -
Classes in org.apache.storm.trident.spout used by org.apache.storm.trident Class Description IBatchSpout IOpaquePartitionedTridentSpout This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.IPartitionedTridentSpout This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident.ITridentSpout -
Classes in org.apache.storm.trident.spout used by org.apache.storm.trident.spout Class Description IBatchID IBatchSpout ICommitterTridentSpout ICommitterTridentSpout.Emitter IOpaquePartitionedTridentSpout This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.IOpaquePartitionedTridentSpout.Coordinator Coordinator for batches.IOpaquePartitionedTridentSpout.Emitter IPartitionedTridentSpout This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.IPartitionedTridentSpout.Coordinator IPartitionedTridentSpout.Emitter ISpoutPartition ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident.ITridentSpout ITridentSpout.BatchCoordinator ITridentSpout.Emitter RichSpoutBatchId -
Classes in org.apache.storm.trident.spout used by org.apache.storm.trident.testing Class Description IBatchSpout ICommitterTridentSpout ICommitterTridentSpout.Emitter ITridentDataSource ITridentDataSource marks all spouts that provide data into Trident.ITridentSpout ITridentSpout.BatchCoordinator ITridentSpout.Emitter -
Classes in org.apache.storm.trident.spout used by org.apache.storm.trident.topology Class Description IBatchID IBatchSpout ITridentSpout