public class JobMasterPartitionTrackerImpl extends AbstractPartitionTracker<ResourceID,ResultPartitionDeploymentDescriptor> implements JobMasterPartitionTracker
Constructor and Description |
---|
JobMasterPartitionTrackerImpl(JobID jobId,
ShuffleMaster<?> shuffleMaster,
PartitionTrackerFactory.TaskExecutorGatewayLookup taskExecutorGatewayLookup) |
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.
|
isPartitionTracked, isTrackingPartitionsFor, stopTrackingPartitions, stopTrackingPartitionsFor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isPartitionTracked, isTrackingPartitionsFor, stopTrackingPartitions, stopTrackingPartitionsFor
public JobMasterPartitionTrackerImpl(JobID jobId, ShuffleMaster<?> shuffleMaster, PartitionTrackerFactory.TaskExecutorGatewayLookup taskExecutorGatewayLookup)
public void startTrackingPartition(ResourceID producingTaskExecutorId, ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)
JobMasterPartitionTracker
startTrackingPartition
in interface JobMasterPartitionTracker
producingTaskExecutorId
- ID of task executor on which the partition is producedresultPartitionDeploymentDescriptor
- deployment descriptor of the partitionpublic void stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds)
JobMasterPartitionTracker
stopTrackingAndReleasePartitions
in interface JobMasterPartitionTracker
public void stopTrackingAndReleasePartitionsFor(ResourceID producingTaskExecutorId)
JobMasterPartitionTracker
stopTrackingAndReleasePartitionsFor
in interface JobMasterPartitionTracker
public void stopTrackingAndReleaseOrPromotePartitionsFor(ResourceID producingTaskExecutorId)
JobMasterPartitionTracker
stopTrackingAndReleaseOrPromotePartitionsFor
in interface JobMasterPartitionTracker
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.