storm.trident.spout
Class OpaquePartitionedTridentSpoutExecutor
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
OpaquePartitionedTridentSpoutExecutor
public OpaquePartitionedTridentSpoutExecutor(IOpaquePartitionedTridentSpout spout)
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>