storm.trident.spout
Interface ITridentSpout<T>

All Superinterfaces:
java.io.Serializable
All Known Subinterfaces:
ICommitterTridentSpout<X>
All Known Implementing Classes:
BatchSpoutExecutor, FeederBatchSpout, FeederCommitterBatchSpout, OpaquePartitionedTridentSpoutExecutor, PartitionedTridentSpoutExecutor, RichSpoutBatchExecutor

public interface ITridentSpout<T>
extends java.io.Serializable


Nested Class Summary
static interface ITridentSpout.BatchCoordinator<X>
           
static interface ITridentSpout.Emitter<X>
           
 
Method Summary
 java.util.Map getComponentConfiguration()
           
 ITridentSpout.BatchCoordinator<T> 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<T> 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()
           
 

Method Detail

getCoordinator

ITridentSpout.BatchCoordinator<T> 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. The Coordinator that you provide in a TransactionalSpout provides metadata for each transaction so that the transactions can be replayed.


getEmitter

ITridentSpout.Emitter<T> getEmitter(java.lang.String txStateId,
                                    java.util.Map conf,
                                    TopologyContext context)
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.


getComponentConfiguration

java.util.Map getComponentConfiguration()

getOutputFields

Fields getOutputFields()