Uses of Interface
org.apache.storm.transactional.ITransactionalSpout.Coordinator

Packages that use ITransactionalSpout.Coordinator

Package	Description
org.apache.storm.transactional
org.apache.storm.transactional.partitioned

Uses of ITransactionalSpout.Coordinator in org.apache.storm.transactional

Methods in org.apache.storm.transactional that return ITransactionalSpout.Coordinator

Modifier and Type	Method and Description
ITransactionalSpout.Coordinator<T>	ITransactionalSpout.getCoordinator(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.

Uses of ITransactionalSpout.Coordinator in org.apache.storm.transactional.partitioned

Classes in org.apache.storm.transactional.partitioned that implement ITransactionalSpout.Coordinator

Modifier and Type	Class and Description
class	OpaquePartitionedTransactionalSpoutExecutor.Coordinator

Methods in org.apache.storm.transactional.partitioned that return ITransactionalSpout.Coordinator

Modifier and Type	Method and Description
ITransactionalSpout.Coordinator	PartitionedTransactionalSpoutExecutor.getCoordinator(Map conf, TopologyContext context)
ITransactionalSpout.Coordinator<Object>	OpaquePartitionedTransactionalSpoutExecutor.getCoordinator(Map conf, TopologyContext context)