public class PartitionTrackerImpl extends Object implements PartitionTracker
Constructor and Description |
---|
PartitionTrackerImpl(JobID jobId,
ShuffleMaster<?> shuffleMaster,
PartitionTrackerFactory.TaskExecutorGatewayLookup taskExecutorGatewayLookup) |
Modifier and Type | Method and Description |
---|---|
boolean |
isPartitionTracked(ResultPartitionID resultPartitionID)
Returns whether the given partition is being tracked.
|
boolean |
isTrackingPartitionsFor(ResourceID producingTaskExecutorId)
Returns whether any partition is being tracked for the given task executor ID.
|
void |
startTrackingPartition(ResourceID producingTaskExecutorId,
ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)
Starts the tracking of the given partition for the given task executor ID.
|
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.
|
void |
stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
Stops the tracking of the given partitions.
|
void |
stopTrackingPartitionsFor(ResourceID producingTaskExecutorId)
Stops the tracking of all partitions for the given task executor ID, without issuing any release calls.
|
public PartitionTrackerImpl(JobID jobId, ShuffleMaster<?> shuffleMaster, PartitionTrackerFactory.TaskExecutorGatewayLookup taskExecutorGatewayLookup)
public void startTrackingPartition(ResourceID producingTaskExecutorId, ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)
PartitionTracker
startTrackingPartition
in interface PartitionTracker
producingTaskExecutorId
- ID of task executor on which the partition is producedresultPartitionDeploymentDescriptor
- deployment descriptor of the partitionpublic void stopTrackingPartitionsFor(ResourceID producingTaskExecutorId)
PartitionTracker
stopTrackingPartitionsFor
in interface PartitionTracker
public void stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds)
PartitionTracker
stopTrackingAndReleasePartitions
in interface PartitionTracker
public void stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
PartitionTracker
stopTrackingPartitions
in interface PartitionTracker
public void stopTrackingAndReleasePartitionsFor(ResourceID producingTaskExecutorId)
PartitionTracker
stopTrackingAndReleasePartitionsFor
in interface PartitionTracker
public boolean isTrackingPartitionsFor(ResourceID producingTaskExecutorId)
PartitionTracker
isTrackingPartitionsFor
in interface PartitionTracker
public boolean isPartitionTracked(ResultPartitionID resultPartitionID)
PartitionTracker
isPartitionTracked
in interface PartitionTracker
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.