storm.trident.spout
Interface ICommitterTridentSpout<X>

All Superinterfaces:

ITridentSpout<X>, java.io.Serializable

All Known Implementing Classes:

FeederCommitterBatchSpout, OpaquePartitionedTridentSpoutExecutor

public interface ICommitterTridentSpout<X>
extends ITridentSpout<X>

Nested Class Summary

static interface

ICommitterTridentSpout.Emitter

Nested classes/interfaces inherited from interface storm.trident.spout.ITridentSpout

ITridentSpout.BatchCoordinator<X>

Method Summary

ICommitterTridentSpout.Emitter

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

Methods inherited from interface storm.trident.spout.ITridentSpout

getComponentConfiguration, getCoordinator, getOutputFields

Method Detail

getEmitter

ICommitterTridentSpout.Emitter getEmitter(java.lang.String txStateId,
                                          java.util.Map conf,
                                          TopologyContext context)

Description copied from interface: ITridentSpout

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 ITridentSpout<X>