public class OpaquePartitionedTransactionalSpoutExecutor.Emitter extends Object implements ICommitterTransactionalSpout.Emitter
| Constructor and Description |
|---|
OpaquePartitionedTransactionalSpoutExecutor.Emitter(Map conf,
TopologyContext context) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanupBefore(BigInteger txid)
Any state for transactions prior to the provided transaction id can be safely cleaned up, so this
method should clean up that state.
|
void |
close()
Release any resources held by this emitter.
|
void |
commit(TransactionAttempt attempt) |
void |
emitBatch(TransactionAttempt tx,
Object coordinatorMeta,
BatchOutputCollector collector)
Emit a batch for the specified transaction attempt and metadata for the transaction.
|
public OpaquePartitionedTransactionalSpoutExecutor.Emitter(Map conf, TopologyContext context)
public void emitBatch(TransactionAttempt tx, Object coordinatorMeta, BatchOutputCollector collector)
ITransactionalSpout.EmitteremitBatch in interface ITransactionalSpout.Emitterpublic void cleanupBefore(BigInteger txid)
ITransactionalSpout.EmittercleanupBefore in interface ITransactionalSpout.Emitterpublic void commit(TransactionAttempt attempt)
commit in interface ICommitterTransactionalSpout.Emitterpublic void close()
ITransactionalSpout.Emitterclose in interface ITransactionalSpout.EmitterCopyright © 2015. All rights reserved.