public static interface ITridentSpout.BatchCoordinator<X>
Modifier and Type | Method and Description |
---|---|
void |
close()
Release any resources from this coordinator.
|
X |
initializeTransaction(long txid,
X prevMetadata,
X currMetadata)
Create metadata for this particular transaction id which has never
been emitted before.
|
boolean |
isReady(long txid) |
void |
success(long txid) |
X initializeTransaction(long txid, X prevMetadata, X currMetadata)
txid
- The id of the transaction.prevMetadata
- The metadata of the previous transactioncurrMetadata
- The metadata for this transaction the last time it was initialized.
null if this is the first attemptvoid success(long txid)
boolean isReady(long txid)
void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.