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>