backtype.storm.transactional.partitioned
Class OpaquePartitionedTransactionalSpoutExecutor

java.lang.Object
  extended by backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor
All Implemented Interfaces:
IComponent, ICommitterTransactionalSpout<java.lang.Object>, ITransactionalSpout<java.lang.Object>, java.io.Serializable

public class OpaquePartitionedTransactionalSpoutExecutor
extends java.lang.Object
implements ICommitterTransactionalSpout<java.lang.Object>

See Also:
Serialized Form

Nested Class Summary
 class OpaquePartitionedTransactionalSpoutExecutor.Coordinator
           
 class OpaquePartitionedTransactionalSpoutExecutor.Emitter
           
 
Constructor Summary
OpaquePartitionedTransactionalSpoutExecutor(IOpaquePartitionedTransactionalSpout spout)
           
 
Method Summary
 void declareOutputFields(OutputFieldsDeclarer declarer)
          Declare the output schema for all the streams of this topology.
 java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
          Declare configuration specific to this component.
 ITransactionalSpout.Coordinator<java.lang.Object> getCoordinator(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.
 ICommitterTransactionalSpout.Emitter getEmitter(java.util.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<java.lang.Object> getCoordinator(java.util.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<java.lang.Object>

getEmitter

public ICommitterTransactionalSpout.Emitter getEmitter(java.util.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<java.lang.Object>
Specified by:
getEmitter in interface ITransactionalSpout<java.lang.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 java.util.Map<java.lang.String,java.lang.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