public interface ResourceManagerPartitionTracker
Modifier and Type | Method and Description |
---|---|
Map<IntermediateDataSetID,DataSetMetaInfo> |
listDataSets()
Returns all data sets for which partitions are being tracked.
|
void |
processTaskExecutorClusterPartitionReport(ResourceID taskExecutorId,
ClusterPartitionReport clusterPartitionReport)
Processes
ClusterPartitionReport of a task executor. |
void |
processTaskExecutorShutdown(ResourceID taskExecutorId)
Processes the shutdown of task executor.
|
CompletableFuture<Void> |
releaseClusterPartitions(IntermediateDataSetID dataSetId)
Issues a release calls to all task executors that are hosting partitions of the given data
set.
|
void processTaskExecutorClusterPartitionReport(ResourceID taskExecutorId, ClusterPartitionReport clusterPartitionReport)
ClusterPartitionReport
of a task executor. Updates the tracking information
for the respective task executor. Any partition no longer being hosted on the task executor
is considered lost, corrupting the corresponding data set. For any such data set this method
issues partition release calls to all task executors that are hosting partitions of this data
set.taskExecutorId
- origin of the reportclusterPartitionReport
- partition reportvoid processTaskExecutorShutdown(ResourceID taskExecutorId)
taskExecutorId
- task executor that shut downCompletableFuture<Void> releaseClusterPartitions(IntermediateDataSetID dataSetId)
dataSetId
- data set to releaseMap<IntermediateDataSetID,DataSetMetaInfo> listDataSets()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.