public class JobShuffleContextImpl extends Object implements JobShuffleContext
JobShuffleContext
.Constructor and Description |
---|
JobShuffleContextImpl(JobID jobId,
JobMasterGateway jobMasterGateway) |
Modifier and Type | Method and Description |
---|---|
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.
|
public JobShuffleContextImpl(JobID jobId, JobMasterGateway jobMasterGateway)
public JobID getJobId()
getJobId
in interface JobShuffleContext
JobID
.public CompletableFuture<?> stopTrackingAndReleasePartitions(Collection<ResultPartitionID> partitionIds)
JobShuffleContext
stopTrackingAndReleasePartitions
in interface JobShuffleContext
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.