public class OpaquePartitionedTransactionalSpoutExecutor.Coordinator extends Object implements ITransactionalSpout.Coordinator<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(BigInteger txid,
Object 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).
|
public Coordinator(Map conf, TopologyContext context)
public Object initializeTransaction(BigInteger txid, Object prevMetadata)
ITransactionalSpout.Coordinator
initializeTransaction
in interface ITransactionalSpout.Coordinator<Object>
txid
- The id of the transaction.prevMetadata
- The metadata of the previous transactionpublic boolean isReady()
ITransactionalSpout.Coordinator
isReady
in interface ITransactionalSpout.Coordinator<Object>
public void close()
ITransactionalSpout.Coordinator
close
in interface ITransactionalSpout.Coordinator<Object>
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.