public class FeederBatchSpout.FeederCoordinator extends Object implements ITridentSpout.BatchCoordinator<Map<Integer,List<List<Object>>>>
Constructor and Description |
---|
FeederCoordinator(int numPartitions) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Release any resources from this coordinator.
|
Map<Integer,List<List<Object>>> |
initializeTransaction(long txid,
Map<Integer,List<List<Object>>> prevMetadata,
Map<Integer,List<List<Object>>> currMetadata)
Create metadata for this particular transaction id which has never
been emitted before.
|
boolean |
isReady(long txid) |
void |
success(long txid) |
public Map<Integer,List<List<Object>>> initializeTransaction(long txid, Map<Integer,List<List<Object>>> prevMetadata, Map<Integer,List<List<Object>>> currMetadata)
ITridentSpout.BatchCoordinator
initializeTransaction
in interface ITridentSpout.BatchCoordinator<Map<Integer,List<List<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
public void success(long txid)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.