Package org.apache.storm.trident.testing
Class FeederBatchSpout.FeederCoordinator
java.lang.Object
org.apache.storm.trident.testing.FeederBatchSpout.FeederCoordinator
- Enclosing class:
- FeederBatchSpout
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Release any resources from this coordinator.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) hint to Storm if the spout is ready for the transaction id.void
success
(long txid) This attempt committed successfully, so all state for this commit and before can be safely cleaned up.
-
Constructor Details
-
FeederCoordinator
public FeederCoordinator(int numPartitions)
-
-
Method Details
-
initializeTransaction
public Map<Integer,List<List<Object>>> initializeTransaction(long txid, Map<Integer, List<List<Object>>> prevMetadata, Map<Integer, List<List<Object>>> currMetadata) Description copied from interface:ITridentSpout.BatchCoordinator
Create metadata for this particular transaction id which has never been emitted before. The metadata should contain whatever is necessary to be able to replay the exact batch for the transaction at a later point.The metadata is stored in Zookeeper.
Storm uses JSON encoding to store the metadata. Only simple types such as numbers, booleans, strings, lists, and maps should be used.
- Specified by:
initializeTransaction
in interfaceITridentSpout.BatchCoordinator<Map<Integer,
List<List<Object>>>> - Parameters:
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 attempt- Returns:
- the metadata for this new transaction
-
close
public void close()Description copied from interface:ITridentSpout.BatchCoordinator
Release any resources from this coordinator. -
success
public void success(long txid) Description copied from interface:ITridentSpout.BatchCoordinator
This attempt committed successfully, so all state for this commit and before can be safely cleaned up. -
isReady
public boolean isReady(long txid) Description copied from interface:ITridentSpout.BatchCoordinator
hint to Storm if the spout is ready for the transaction id.
-