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

Packages that use ITridentSpout.BatchCoordinator

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

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

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

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

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

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

Modifier and Type	Class	Description
static class	BatchSpoutExecutor.EmptyCoordinator
class	OpaquePartitionedTridentSpoutExecutor.Coordinator

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

Modifier and Type	Method	Description
ITridentSpout.BatchCoordinator<Object>	BatchSpoutExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<T>	ITridentSpout.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)	The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted.
ITridentSpout.BatchCoordinator<Object>	OpaquePartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	PartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	RichSpoutBatchExecutor.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)

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

Classes in org.apache.storm.trident.testing that implement ITridentSpout.BatchCoordinator

Modifier and Type	Class	Description
class	FeederBatchSpout.FeederCoordinator

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

Modifier and Type	Method	Description
ITridentSpout.BatchCoordinator<Map<Integer,List<List<Object>>>>	FeederBatchSpout.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Map<Integer,List<List<Object>>>>	FeederCommitterBatchSpout.getCoordinator(String txStateId, Map<String,Object> conf, TopologyContext context)