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

Packages that use ITridentSpout.BatchCoordinator

Package	Description
storm.trident.spout
storm.trident.testing

Uses of ITridentSpout.BatchCoordinator in storm.trident.spout

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

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

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

Modifier and Type	Method and Description
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 and when transactions should commit.
ITridentSpout.BatchCoordinator	PartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator	BatchSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator<Object>	OpaquePartitionedTridentSpoutExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout.BatchCoordinator	RichSpoutBatchExecutor.getCoordinator(String txStateId, Map conf, TopologyContext context)

Uses of ITridentSpout.BatchCoordinator in storm.trident.testing

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

Modifier and Type	Class and Description
class	FeederBatchSpout.FeederCoordinator

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

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