org.apache.storm.transactional.partitioned

Class OpaquePartitionedTransactionalSpoutExecutor

java.lang.Object

org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor

All Implemented Interfaces:

Serializable, IComponent, ICommitterTransactionalSpout<Object>, ITransactionalSpout<Object>

public class OpaquePartitionedTransactionalSpoutExecutor
extends Object
implements ICommitterTransactionalSpout<Object>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	OpaquePartitionedTransactionalSpoutExecutor.Coordinator
class	OpaquePartitionedTransactionalSpoutExecutor.Emitter

Constructor Summary

Constructors

Constructor and Description
OpaquePartitionedTransactionalSpoutExecutor(IOpaquePartitionedTransactionalSpout spout)

Method Summary

Modifier and Type	Method and Description
void	declareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.
Map<String,Object>	getComponentConfiguration() Declare configuration specific to this component.
ITransactionalSpout.Coordinator<Object>	getCoordinator(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.
ICommitterTransactionalSpout.Emitter	getEmitter(Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

OpaquePartitionedTransactionalSpoutExecutor

public OpaquePartitionedTransactionalSpoutExecutor(IOpaquePartitionedTransactionalSpout spout)

Method Detail

getCoordinator

public ITransactionalSpout.Coordinator<Object> getCoordinator(Map conf,
                                                              TopologyContext context)

Description copied from interface: ITransactionalSpout

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 ITransactionalSpout<Object>

getEmitter

public ICommitterTransactionalSpout.Emitter getEmitter(Map conf,
                                                       TopologyContext context)

Description copied from interface: ITransactionalSpout

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 ICommitterTransactionalSpout<Object>

Specified by:

getEmitter in interface ITransactionalSpout<Object>

declareOutputFields

public void declareOutputFields(OutputFieldsDeclarer declarer)

Description copied from interface: IComponent

Declare the output schema for all the streams of this topology.

Specified by:

declareOutputFields in interface IComponent

Parameters:

declarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Description copied from interface: IComponent

Declare configuration specific to this component. Only a subset of the “topology.*” configs can be overridden. The component configuration can be further overridden when constructing the topology using TopologyBuilder

Specified by:

getComponentConfiguration in interface IComponent