Class AbstractPartitionTracker<K,M>
- java.lang.Object
-
- org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker<K,M>
-
- All Implemented Interfaces:
PartitionTracker<K,M>
- Direct Known Subclasses:
JobMasterPartitionTrackerImpl
,TaskExecutorPartitionTrackerImpl
public abstract class AbstractPartitionTracker<K,M> extends Object implements PartitionTracker<K,M>
Base partition tracker implementation, providing underlying data-structures for storing partitions, their associated keys and meta-information.
-
-
Field Summary
Fields Modifier and Type Field Description protected Map<ResultPartitionID,org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker.PartitionInfo<K,M>>
partitionInfos
protected PartitionTable<K>
partitionTable
-
Constructor Summary
Constructors Constructor Description AbstractPartitionTracker()
-
Method Summary
All Methods Instance Methods Concrete 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.
-
-
-
Field Detail
-
partitionTable
protected final PartitionTable<K> partitionTable
-
partitionInfos
protected final Map<ResultPartitionID,org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker.PartitionInfo<K,M>> partitionInfos
-
-
Method Detail
-
stopTrackingPartitionsFor
public Collection<PartitionTrackerEntry<K,M>> stopTrackingPartitionsFor(K key)
Description copied from interface:PartitionTracker
Stops the tracking of all partitions for the given key.- Specified by:
stopTrackingPartitionsFor
in interfacePartitionTracker<K,M>
-
stopTrackingPartitions
public Collection<PartitionTrackerEntry<K,M>> stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
Description copied from interface:PartitionTracker
Stops the tracking of the given partitions.- Specified by:
stopTrackingPartitions
in interfacePartitionTracker<K,M>
-
isTrackingPartitionsFor
public boolean isTrackingPartitionsFor(K key)
Description copied from interface:PartitionTracker
Returns whether any partition is being tracked for the given key.- Specified by:
isTrackingPartitionsFor
in interfacePartitionTracker<K,M>
-
isPartitionTracked
public boolean isPartitionTracked(ResultPartitionID resultPartitionID)
Description copied from interface:PartitionTracker
Returns whether the given partition is being tracked.- Specified by:
isPartitionTracked
in interfacePartitionTracker<K,M>
-
-