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

Class JobMasterPartitionTrackerImpl

java.lang.Object

org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker<ResourceID,ResultPartitionDeploymentDescriptor>

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

All Implemented Interfaces:

JobMasterPartitionTracker, PartitionTracker<ResourceID,ResultPartitionDeploymentDescriptor>

public class JobMasterPartitionTrackerImpl
extends AbstractPartitionTracker<ResourceID,ResultPartitionDeploymentDescriptor>
implements JobMasterPartitionTracker

Utility for tracking partitions and issuing release calls to task executors and shuffle masters.

Field Summary

Fields inherited from class org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker

partitionInfos, partitionTable

Constructor Summary

Constructors

Constructor and Description
JobMasterPartitionTrackerImpl(JobID jobId, ShuffleMaster<?> shuffleMaster, PartitionTrackerFactory.TaskExecutorGatewayLookup taskExecutorGatewayLookup)

Method Summary

Modifier and Type	Method and Description
Collection<ResultPartitionDeploymentDescriptor>	getAllTrackedPartitions() Get all the partitions under tracking.
void	startTrackingPartition(ResourceID producingTaskExecutorId, ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor) Starts the tracking of the given partition for the given task executor ID.
void	stopTrackingAndReleaseOrPromotePartitions(Collection<ResultPartitionID> resultPartitionIds) Releases the job partitions and promotes the cluster partitions, and stops the tracking of partitions that were released/promoted.
void	stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds, boolean releaseOnShuffleMaster) Releases the given partitions and stop the tracking of partitions that were released.

Methods inherited from class org.apache.flink.runtime.io.network.partition.AbstractPartitionTracker

isPartitionTracked, isTrackingPartitionsFor, stopTrackingPartitions, stopTrackingPartitionsFor

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.io.network.partition.JobMasterPartitionTracker

stopTrackingAndReleasePartitions

Methods inherited from interface org.apache.flink.runtime.io.network.partition.PartitionTracker

isPartitionTracked, isTrackingPartitionsFor, stopTrackingPartitions, stopTrackingPartitionsFor

Constructor Detail

JobMasterPartitionTrackerImpl

public JobMasterPartitionTrackerImpl(JobID jobId,
                                     ShuffleMaster<?> shuffleMaster,
                                     PartitionTrackerFactory.TaskExecutorGatewayLookup taskExecutorGatewayLookup)

Method Detail

startTrackingPartition

public void startTrackingPartition(ResourceID producingTaskExecutorId,
                                   ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)

Description copied from interface: JobMasterPartitionTracker

Starts the tracking of the given partition for the given task executor ID.

Specified by:

startTrackingPartition in interface JobMasterPartitionTracker

Parameters:

producingTaskExecutorId - ID of task executor on which the partition is produced

resultPartitionDeploymentDescriptor - deployment descriptor of the partition

stopTrackingAndReleasePartitions

public void stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds,
                                             boolean releaseOnShuffleMaster)

Description copied from interface: JobMasterPartitionTracker

Releases the given partitions and stop the tracking of partitions that were released. The boolean flag indicates whether we need to notify the ShuffleMaster to release all external resources or not.

Specified by:

stopTrackingAndReleasePartitions in interface JobMasterPartitionTracker

stopTrackingAndReleaseOrPromotePartitions

public void stopTrackingAndReleaseOrPromotePartitions(Collection<ResultPartitionID> resultPartitionIds)

Description copied from interface: JobMasterPartitionTracker

Releases the job partitions and promotes the cluster partitions, and stops the tracking of partitions that were released/promoted.

Specified by:

stopTrackingAndReleaseOrPromotePartitions in interface JobMasterPartitionTracker

getAllTrackedPartitions

public Collection<ResultPartitionDeploymentDescriptor> getAllTrackedPartitions()

Description copied from interface: JobMasterPartitionTracker

Get all the partitions under tracking.

Specified by:

getAllTrackedPartitions in interface JobMasterPartitionTracker