public static interface ITransactionalSpout.Emitter<X>
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 |
emitBatch(TransactionAttempt tx,
X coordinatorMeta,
BatchOutputCollector collector)
Emit a batch for the specified transaction attempt and metadata for the transaction.
|
void emitBatch(TransactionAttempt tx, X coordinatorMeta, BatchOutputCollector collector)
void cleanupBefore(BigInteger txid)
void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.