Package org.apache.flink.runtime.shuffle
Interface JobShuffleContext
-
- All Known Implementing Classes:
JobShuffleContextImpl
public interface JobShuffleContextJob level shuffle context which can offer some job information like job ID and through it, the shuffle plugin notify the job to stop tracking the lost result partitions.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.flink.api.common.JobIDgetJobId()CompletableFuture<?>stopTrackingAndReleasePartitions(Collection<ResultPartitionID> partitionIds)Notifies the job to stop tracking and release the target result partitions, which means these partitions will be removed and will be reproduced if used afterwards.
-
-
-
Method Detail
-
getJobId
org.apache.flink.api.common.JobID getJobId()
- Returns:
- the corresponding
JobID.
-
stopTrackingAndReleasePartitions
CompletableFuture<?> stopTrackingAndReleasePartitions(Collection<ResultPartitionID> partitionIds)
Notifies the job to stop tracking and release the target result partitions, which means these partitions will be removed and will be reproduced if used afterwards.
-
-