org.apache.flink.runtime.io.network.partition

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

Modifier and Type	Method and 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.