public class OpaquePartitionedTridentSpoutExecutor.Coordinator extends Object implements ITridentSpout.BatchCoordinator<Object>
Constructor and Description |
---|
Coordinator(Map conf,
TopologyContext context) |
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 Coordinator(Map conf, TopologyContext context)
public Object initializeTransaction(long txid, Object prevMetadata, Object currMetadata)
ITridentSpout.BatchCoordinator
initializeTransaction
in interface ITridentSpout.BatchCoordinator<Object>
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<Object>
public void success(long txid)
success
in interface ITridentSpout.BatchCoordinator<Object>
public boolean isReady(long txid)
isReady
in interface ITridentSpout.BatchCoordinator<Object>
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.