public interface JobMasterPartitionTracker extends PartitionTracker<ResourceID,ResultPartitionDeploymentDescriptor>
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.
|
default void |
stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds)
Releases the given partitions and stop the tracking of partitions that were released.
|
void |
stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds,
boolean releaseOnShuffleMaster)
Releases the given partitions and stop the tracking of partitions that were released.
|
isPartitionTracked, isTrackingPartitionsFor, stopTrackingPartitions, stopTrackingPartitionsFor
void startTrackingPartition(ResourceID producingTaskExecutorId, ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)
producingTaskExecutorId
- ID of task executor on which the partition is producedresultPartitionDeploymentDescriptor
- deployment descriptor of the partitiondefault void stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds)
void stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds, boolean releaseOnShuffleMaster)
void stopTrackingAndReleaseOrPromotePartitions(Collection<ResultPartitionID> resultPartitionIds)
Collection<ResultPartitionDeploymentDescriptor> getAllTrackedPartitions()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.