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

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 and Description
protected Map<ResultPartitionID,org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker.PartitionInfo<K,M>>	partitionInfos
protected PartitionTable<K>	partitionTable

Constructor Summary

Constructors

Constructor and Description
AbstractPartitionTracker()

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

Constructor Detail

AbstractPartitionTracker

public AbstractPartitionTracker()

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 interface PartitionTracker<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 interface PartitionTracker<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 interface PartitionTracker<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 interface PartitionTracker<K,M>