Uses of Interface
org.apache.storm.trident.spout.ITridentDataSource
-
-
Uses of ITridentDataSource in org.apache.storm.hdfs.trident
Classes in org.apache.storm.hdfs.trident that implement ITridentDataSource Modifier and Type Class Description classFixedBatchSpout -
Uses of ITridentDataSource in org.apache.storm.hive.trident
Classes in org.apache.storm.hive.trident that implement ITridentDataSource Modifier and Type Class Description static classTridentHiveTopology.FixedBatchSpout -
Uses of ITridentDataSource in org.apache.storm.jms.trident
Classes in org.apache.storm.jms.trident that implement ITridentDataSource Modifier and Type Class Description classTridentJmsSpoutTrident 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 Description classKafkaTridentSpoutOpaque<K,V>classKafkaTridentSpoutTransactional<K,V> -
Uses of ITridentDataSource in org.apache.storm.kafka.trident
Methods in org.apache.storm.kafka.trident with parameters of type ITridentDataSource Modifier and Type Method Description static StormTopologyTridentKafkaConsumerTopology. newTopology(ITridentDataSource tridentSpout)Creates a new topology that prints inputs to stdout. -
Uses of ITridentDataSource in org.apache.storm.starter.spout
Classes in org.apache.storm.starter.spout that implement ITridentDataSource Modifier and Type Class Description classRandomNumberGeneratorSpoutThis spout generates random whole numbers with givenmaxNumbervalue as maximum with the givenfields. -
Uses of ITridentDataSource in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type ITridentDataSource Modifier and Type Method Description StreamTridentTopology. 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 Description interfaceIBatchSpoutinterfaceICommitterTridentSpout<X>interfaceIOpaquePartitionedTridentSpout<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.interfaceIPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.interfaceITridentSpout<T>Classes in org.apache.storm.trident.spout that implement ITridentDataSource Modifier and Type Class Description classBatchSpoutExecutorclassOpaquePartitionedTridentSpoutExecutorclassPartitionedTridentSpoutExecutorclassRichSpoutBatchExecutor -
Uses of ITridentDataSource in org.apache.storm.trident.testing
Classes in org.apache.storm.trident.testing that implement ITridentDataSource Modifier and Type Class Description classFeederBatchSpoutclassFeederCommitterBatchSpoutclassFixedBatchSpout
-