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 and Description
ITridentSpout.BatchCoordinator<JmsBatch>	TridentJmsSpout.getCoordinator(String txStateId, Map 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 and Description
static class	BatchSpoutExecutor.EmptyCoordinator
class	OpaquePartitionedTridentSpoutExecutor.Coordinator

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

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

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

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