public static interface ITransactionalSpout.Coordinator<X>
Modifier and Type | Method and Description |
---|---|
void |
close()
Release any resources from this coordinator.
|
X |
initializeTransaction(BigInteger txid,
X prevMetadata)
Create metadata for this particular transaction id which has never
been emitted before.
|
boolean |
isReady()
Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction).
|
X initializeTransaction(BigInteger txid, X prevMetadata)
txid
- The id of the transaction.prevMetadata
- The metadata of the previous transactionboolean isReady()
void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.