Interface PartitionTracker<K,M>
-
- All Known Subinterfaces:
JobMasterPartitionTracker
,TaskExecutorPartitionTracker
- All Known Implementing Classes:
AbstractPartitionTracker
,JobMasterPartitionTrackerImpl
,TaskExecutorPartitionTrackerImpl
public interface PartitionTracker<K,M>
Utility for tracking partitions.This interface deliberately does not have a method to start tracking partitions, so that implementation are flexible in their definitions for this method (otherwise one would end up with multiple methods, with one part likely being unused).
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description boolean
isPartitionTracked(ResultPartitionID resultPartitionID)
Returns whether the given partition is being tracked.boolean
isTrackingPartitionsFor(K key)
Returns whether any partition is being tracked for the given key.Collection<PartitionTrackerEntry<K,M>>
stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
Stops the tracking of the given partitions.Collection<PartitionTrackerEntry<K,M>>
stopTrackingPartitionsFor(K key)
Stops the tracking of all partitions for the given key.
-
-
-
Method Detail
-
stopTrackingPartitionsFor
Collection<PartitionTrackerEntry<K,M>> stopTrackingPartitionsFor(K key)
Stops the tracking of all partitions for the given key.
-
stopTrackingPartitions
Collection<PartitionTrackerEntry<K,M>> stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
Stops the tracking of the given partitions.
-
isTrackingPartitionsFor
boolean isTrackingPartitionsFor(K key)
Returns whether any partition is being tracked for the given key.
-
isPartitionTracked
boolean isPartitionTracked(ResultPartitionID resultPartitionID)
Returns whether the given partition is being tracked.
-
-