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