public class OpaquePartitionedTransactionalSpoutExecutor.Emitter extends Object implements ICommitterTransactionalSpout.Emitter
Constructor and Description |
---|
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 Emitter(Map conf, TopologyContext context)
public void emitBatch(TransactionAttempt tx, Object coordinatorMeta, BatchOutputCollector collector)
ITransactionalSpout.Emitter
emitBatch
in interface ITransactionalSpout.Emitter
public void cleanupBefore(BigInteger txid)
ITransactionalSpout.Emitter
cleanupBefore
in interface ITransactionalSpout.Emitter
public void commit(TransactionAttempt attempt)
commit
in interface ICommitterTransactionalSpout.Emitter
public void close()
ITransactionalSpout.Emitter
close
in interface ITransactionalSpout.Emitter
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.