storm.trident.spout
Class OpaquePartitionedTridentSpoutExecutor

java.lang.Object
  extended by storm.trident.spout.OpaquePartitionedTridentSpoutExecutor
All Implemented Interfaces:
java.io.Serializable, ICommitterTridentSpout<java.lang.Object>, ITridentSpout<java.lang.Object>

public class OpaquePartitionedTridentSpoutExecutor
extends java.lang.Object
implements ICommitterTridentSpout<java.lang.Object>

See Also:
Serialized Form

Nested Class Summary
 class OpaquePartitionedTridentSpoutExecutor.Coordinator
           
 class OpaquePartitionedTridentSpoutExecutor.Emitter
           
 
Nested classes/interfaces inherited from interface storm.trident.spout.ITridentSpout
ITridentSpout.BatchCoordinator<X>
 
Constructor Summary
OpaquePartitionedTridentSpoutExecutor(IOpaquePartitionedTridentSpout spout)
           
 
Method Summary
 java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
           
 ITridentSpout.BatchCoordinator<java.lang.Object> 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.
 ICommitterTridentSpout.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
 

Constructor Detail

OpaquePartitionedTridentSpoutExecutor

public OpaquePartitionedTridentSpoutExecutor(IOpaquePartitionedTridentSpout spout)
Method Detail

getCoordinator

public ITridentSpout.BatchCoordinator<java.lang.Object> 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<java.lang.Object>

getEmitter

public ICommitterTridentSpout.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 ICommitterTridentSpout<java.lang.Object>
Specified by:
getEmitter in interface ITridentSpout<java.lang.Object>

getOutputFields

public Fields getOutputFields()
Specified by:
getOutputFields in interface ITridentSpout<java.lang.Object>

getComponentConfiguration

public java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
Specified by:
getComponentConfiguration in interface ITridentSpout<java.lang.Object>