|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public static interface ITransactionalSpout.Emitter<X>
Method Summary | |
---|---|
void |
cleanupBefore(java.math.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. |
Method Detail |
---|
void emitBatch(TransactionAttempt tx, X coordinatorMeta, BatchOutputCollector collector)
void cleanupBefore(java.math.BigInteger txid)
void close()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |