storm.trident.spout

Class PartitionedTridentSpoutExecutor

java.lang.Object

storm.trident.spout.PartitionedTridentSpoutExecutor

All Implemented Interfaces:

Serializable, ITridentSpout<Integer>

public class PartitionedTridentSpoutExecutor
extends Object
implements ITridentSpout<Integer>

See Also:

Serialized Form

Nested Class Summary

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

ITridentSpout.BatchCoordinator<X>

Constructor Summary

Constructors

Constructor and Description
PartitionedTridentSpoutExecutor(IPartitionedTridentSpout spout)

Method Summary

Methods

Modifier and Type	Method and Description
Map<String,Object>	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()
IPartitionedTridentSpout	getPartitionedSpout()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionedTridentSpoutExecutor

public PartitionedTridentSpoutExecutor(IPartitionedTridentSpout spout)

Method Detail

getPartitionedSpout

public IPartitionedTridentSpout getPartitionedSpout()

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<Integer>

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<Integer>

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface ITridentSpout<Integer>

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface ITridentSpout<Integer>