storm.trident.spout
Class RichSpoutBatchExecutor

java.lang.Object
  storm.trident.spout.RichSpoutBatchExecutor

All Implemented Interfaces:

java.io.Serializable, ITridentSpout

public class RichSpoutBatchExecutor
extends java.lang.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

static java.lang.String

MAX_BATCH_SIZE_CONF

Constructor Summary

RichSpoutBatchExecutor(IRichSpout spout)

Method Summary

java.util.Map	getComponentConfiguration()
ITridentSpout.BatchCoordinator	getCoordinator(java.lang.String txStateId, java.util.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(java.lang.String txStateId, java.util.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 java.lang.String MAX_BATCH_SIZE_CONF

See Also:

Constant Field Values

Constructor Detail

RichSpoutBatchExecutor

public RichSpoutBatchExecutor(IRichSpout spout)

Method Detail

getComponentConfiguration

public java.util.Map getComponentConfiguration()

Specified by:

getComponentConfiguration in interface ITridentSpout

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface ITridentSpout

getCoordinator

public ITridentSpout.BatchCoordinator getCoordinator(java.lang.String txStateId,
                                                     java.util.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(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