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

Interface JobMasterPartitionTracker

All Superinterfaces:

PartitionTracker<ResourceID,ResultPartitionDeploymentDescriptor>

All Known Implementing Classes:

JobMasterPartitionTrackerImpl

public interface JobMasterPartitionTracker
extends PartitionTracker<ResourceID,ResultPartitionDeploymentDescriptor>

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

Method Summary

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

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

isPartitionTracked, isTrackingPartitionsFor, stopTrackingPartitions, stopTrackingPartitionsFor

Method Detail

startTrackingPartition

void startTrackingPartition(ResourceID producingTaskExecutorId,
                            ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)

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

Parameters:

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

resultPartitionDeploymentDescriptor - deployment descriptor of the partition

stopTrackingAndReleasePartitions

void stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds)

Releases the given partitions and stop the tracking of partitions that were released.

stopTrackingAndReleasePartitionsFor

void stopTrackingAndReleasePartitionsFor(ResourceID producingTaskExecutorId)

Releases all partitions for the given task executor ID, and stop the tracking of partitions that were released.

stopTrackingAndReleaseOrPromotePartitionsFor

void stopTrackingAndReleaseOrPromotePartitionsFor(ResourceID producingTaskExecutorId)

Releases all job partitions and promotes all cluster partitions for the given task executor ID, and stops the tracking of partitions that were released/promoted.