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<String,Object> 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<Object>	RichSpoutBatchExecutor.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<Object>	PartitionedTridentSpoutExecutor.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.Emitter<T>	ITridentSpout.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
ITridentSpout.Emitter<Object>	BatchSpoutExecutor.getEmitter(String txStateId, Map<String,Object> 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<Map<Integer,List<List<Object>>>>	FeederBatchSpout.getEmitter(String txStateId, Map<String,Object> conf, TopologyContext context)