JobShuffleContextImpl (Flink : Runtime 1.19.3-cp2 API)

java.lang.Object
- org.apache.flink.runtime.shuffle.JobShuffleContextImpl

All Implemented Interfaces:

JobShuffleContext
```
public class JobShuffleContextImpl
extends Object
implements JobShuffleContext
```
The default implementation of JobShuffleContext.

Constructor Summary

Constructors
Constructor Description

JobShuffleContextImpl(org.apache.flink.api.common.JobID jobId, JobMasterGateway jobMasterGateway)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.api.common.JobID`	`getJobId()`
`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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - JobShuffleContextImpl
```
public JobShuffleContextImpl(org.apache.flink.api.common.JobID jobId,
                             JobMasterGateway jobMasterGateway)
```
- Method Detail
  - getJobId
```
public org.apache.flink.api.common.JobID getJobId()
```
    Specified by:
    
    getJobId in interface JobShuffleContext
    
    Returns:
    
    the corresponding JobID.
  - stopTrackingAndReleasePartitions
```
public CompletableFuture<?> stopTrackingAndReleasePartitions(Collection<ResultPartitionID> partitionIds)
```
    Description copied from interface: JobShuffleContext
    
    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.
    
    Specified by:
    
    stopTrackingAndReleasePartitions in interface JobShuffleContext