storm.trident.spout

Class RichSpoutBatchExecutor

java.lang.Object

storm.trident.spout.RichSpoutBatchExecutor

All Implemented Interfaces:

Serializable, ITridentSpout

public class RichSpoutBatchExecutor
extends Object
implements ITridentSpout

See Also:

Serialized Form

Nested Class Summary

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

ITridentSpout.BatchCoordinator<X>, ITridentSpout.Emitter<X>

Field Summary

Fields

Modifier and Type	Field and Description
static String	MAX_BATCH_SIZE_CONF

Constructor Summary

Constructors

Constructor and Description
RichSpoutBatchExecutor(IRichSpout spout)

Method Summary

Methods

Modifier and Type	Method and Description
Map	getComponentConfiguration()
ITridentSpout.BatchCoordinator	getCoordinator(String txStateId, Map conf, TopologyContext context) The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit.
ITridentSpout.Emitter	getEmitter(String txStateId, Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
Fields	getOutputFields()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_BATCH_SIZE_CONF

public static final String MAX_BATCH_SIZE_CONF

See Also:

Constant Field Values

Constructor Detail

RichSpoutBatchExecutor

public RichSpoutBatchExecutor(IRichSpout spout)

Method Detail

getComponentConfiguration

public Map getComponentConfiguration()

Specified by:

getComponentConfiguration in interface ITridentSpout

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface ITridentSpout

getCoordinator

public ITridentSpout.BatchCoordinator getCoordinator(String txStateId,
                                            Map conf,
                                            TopologyContext context)

Description copied from interface: ITridentSpout

The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit. The Coordinator that you provide in a TransactionalSpout provides metadata for each transaction so that the transactions can be replayed.

Specified by:

getCoordinator in interface ITridentSpout

getEmitter

public ITridentSpout.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