storm.trident.spout

Interface ICommitterTridentSpout<X>

All Superinterfaces:

ITridentSpout<X>, Serializable

All Known Implementing Classes:

FeederCommitterBatchSpout, OpaquePartitionedTridentSpoutExecutor

public interface ICommitterTridentSpout<X>
extends ITridentSpout<X>

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ICommitterTridentSpout.Emitter

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

ITridentSpout.BatchCoordinator<X>

Method Summary

Methods

Modifier and Type	Method and Description
ICommitterTridentSpout.Emitter	getEmitter(String txStateId, 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(String txStateId,
                                        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>