public static class BatchSpoutExecutor.EmptyCoordinator extends Object implements ITridentSpout.BatchCoordinator
Constructor and Description |
---|
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.BatchCoordinator
initializeTransaction
in interface ITridentSpout.BatchCoordinator
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 attemptpublic void close()
ITridentSpout.BatchCoordinator
close
in interface ITridentSpout.BatchCoordinator
public void success(long txid)
success
in interface ITridentSpout.BatchCoordinator
public boolean isReady(long txid)
isReady
in interface ITridentSpout.BatchCoordinator
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.