Uses of Interface
org.apache.storm.trident.spout.ITridentSpout.Emitter
Package
Description
-
Uses of ITridentSpout.Emitter in org.apache.storm.jms.trident
Modifier and TypeMethodDescriptionTridentJmsSpout.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context) -
Uses of ITridentSpout.Emitter in org.apache.storm.trident.spout
Modifier and TypeClassDescriptionclass
class
Modifier and TypeMethodDescriptionBatchSpoutExecutor.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context) ITridentSpout.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.PartitionedTridentSpoutExecutor.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context) RichSpoutBatchExecutor.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context) -
Uses of ITridentSpout.Emitter in org.apache.storm.trident.testing
Modifier and TypeMethodDescriptionFeederBatchSpout.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context)