Uses of Interface
org.apache.storm.trident.spout.ITridentSpout.Emitter

Packages that use ITridentSpout.Emitter

Package	Description
org.apache.storm.jms.trident
org.apache.storm.trident.spout
org.apache.storm.trident.testing

Uses of ITridentSpout.Emitter in org.apache.storm.jms.trident

Methods in org.apache.storm.jms.trident that return ITridentSpout.Emitter

Modifier and Type	Method and Description
ITridentSpout.Emitter<JmsBatch>	TridentJmsSpout.getEmitter(String txStateId, Map conf, TopologyContext context)

Uses of ITridentSpout.Emitter in org.apache.storm.trident.spout

Subinterfaces of ITridentSpout.Emitter in org.apache.storm.trident.spout

Modifier and Type	Interface and Description
static interface	ICommitterTridentSpout.Emitter

Classes in org.apache.storm.trident.spout that implement ITridentSpout.Emitter

Modifier and Type	Class and Description
class	BatchSpoutExecutor.BatchSpoutEmitter
class	OpaquePartitionedTridentSpoutExecutor.Emitter

Methods in org.apache.storm.trident.spout that return ITridentSpout.Emitter

Modifier and Type	Method and Description
ITridentSpout.Emitter	RichSpoutBatchExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter<Object>	PartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout.Emitter<T>	ITridentSpout.getEmitter(String txStateId, Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
ITridentSpout.Emitter	BatchSpoutExecutor.getEmitter(String txStateId, Map conf, TopologyContext context)

Uses of ITridentSpout.Emitter in org.apache.storm.trident.testing

Methods in org.apache.storm.trident.testing that return ITridentSpout.Emitter

Modifier and Type	Method and Description
ITridentSpout.Emitter	FeederBatchSpout.getEmitter(String txStateId, Map conf, TopologyContext context)