backtype.storm.transactional
Interface ICommitterTransactionalSpout<X>

All Superinterfaces:

IComponent, ITransactionalSpout<X>, java.io.Serializable

All Known Implementing Classes:

OpaquePartitionedTransactionalSpoutExecutor

public interface ICommitterTransactionalSpout<X>
extends ITransactionalSpout<X>

Nested Class Summary

static interface

ICommitterTransactionalSpout.Emitter

Nested classes/interfaces inherited from interface backtype.storm.transactional.ITransactionalSpout

ITransactionalSpout.Coordinator<X>

Method Summary

ICommitterTransactionalSpout.Emitter

getEmitter(java.util.Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.

Methods inherited from interface backtype.storm.transactional.ITransactionalSpout

getCoordinator

Methods inherited from interface backtype.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

getEmitter

ICommitterTransactionalSpout.Emitter getEmitter(java.util.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>