Uses of Interface
org.apache.storm.trident.spout.ITridentDataSource
Package
Description
ElasticSearch Trident example classes.
-
Uses of ITridentDataSource in org.apache.storm.elasticsearch.trident
Modifier and TypeClassDescriptionstatic class
A fixed batch spout. -
Uses of ITridentDataSource in org.apache.storm.hdfs.trident
-
Uses of ITridentDataSource in org.apache.storm.hive.trident
-
Uses of ITridentDataSource in org.apache.storm.jms.trident
-
Uses of ITridentDataSource in org.apache.storm.kafka.spout.trident
Modifier and TypeClassDescriptionclass
class
-
Uses of ITridentDataSource in org.apache.storm.kafka.trident
Modifier and TypeMethodDescriptionstatic StormTopology
TridentKafkaConsumerTopology.newTopology
(ITridentDataSource tridentSpout) Creates a new topology that prints inputs to stdout. -
Uses of ITridentDataSource in org.apache.storm.starter.spout
Modifier and TypeClassDescriptionclass
This spout generates random whole numbers with givenmaxNumber
value as maximum with the givenfields
. -
Uses of ITridentDataSource in org.apache.storm.trident
Modifier and TypeMethodDescriptionTridentTopology.newStream
(String txId, ITridentDataSource dataSource) -
Uses of ITridentDataSource in org.apache.storm.trident.spout
Modifier and TypeInterfaceDescriptioninterface
interface
interface
IOpaquePartitionedTridentSpout<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.interface
IPartitionedTridentSpout<PartitionsT,
PartitionT extends ISpoutPartition, T> This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.interface
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of ITridentDataSource in org.apache.storm.trident.testing
Modifier and TypeClassDescriptionclass
class
class