Package org.apache.storm.trident.spout
Interface IPartitionedTridentSpout.Coordinator<PartitionsT>
- All Known Implementing Classes:
- KafkaTridentSpoutCoordinator
- Enclosing interface:
- IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition, T> 
public static interface IPartitionedTridentSpout.Coordinator<PartitionsT>
- 
Method Details- 
getPartitionsForBatchPartitionsT getPartitionsForBatch()Return the partitions currently in the source of data. The idea is is that if a new partition is added and a prior transaction is replayed, it doesn't emit tuples for the new partition because it knows what partitions were in that transaction.
- 
isReadyboolean isReady(long txid) 
- 
closevoid close()
 
-