org.apache.storm.transactional

Interface ICommitterTransactionalSpout<X>

All Superinterfaces:

IComponent, ITransactionalSpout<X>, Serializable

All Known Implementing Classes:

OpaquePartitionedTransactionalSpoutExecutor

public interface ICommitterTransactionalSpout<X>
extends ITransactionalSpout<X>

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ICommitterTransactionalSpout.Emitter

Nested classes/interfaces inherited from interface org.apache.storm.transactional.ITransactionalSpout

ITransactionalSpout.Coordinator<X>

Method Summary

Modifier and Type	Method and Description
ICommitterTransactionalSpout.Emitter	getEmitter(Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.

Methods inherited from interface org.apache.storm.transactional.ITransactionalSpout

getCoordinator

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

getEmitter

ICommitterTransactionalSpout.Emitter getEmitter(Map conf,
                                                TopologyContext context)

Description copied from interface: ITransactionalSpout

The emitter for a TransactionalSpout runs as many tasks across the cluster. Emitters are responsible for emitting batches of tuples for a transaction and must ensure that the same batch of tuples is always emitted for the same transaction id.

Specified by:

getEmitter in interface ITransactionalSpout<X>