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
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()