public static class BatchSpoutExecutor.EmptyCoordinator extends Object implements ITridentSpout.BatchCoordinator
| Constructor and Description |
|---|
BatchSpoutExecutor.EmptyCoordinator() |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Release any resources from this coordinator.
|
Object |
initializeTransaction(long txid,
Object prevMetadata,
Object currMetadata)
Create metadata for this particular transaction id which has never
been emitted before.
|
boolean |
isReady(long txid) |
void |
success(long txid) |
public Object initializeTransaction(long txid, Object prevMetadata, Object currMetadata)
ITridentSpout.BatchCoordinatorinitializeTransaction in interface ITridentSpout.BatchCoordinatortxid - 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 attemptpublic void close()
ITridentSpout.BatchCoordinatorclose in interface ITridentSpout.BatchCoordinatorpublic void success(long txid)
success in interface ITridentSpout.BatchCoordinatorpublic boolean isReady(long txid)
isReady in interface ITridentSpout.BatchCoordinatorCopyright © 2015. All rights reserved.