Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager.slotmanager |
Modifier and Type | Method and Description |
---|---|
static PendingTaskManagerId |
PendingTaskManagerId.generate() |
PendingTaskManagerId |
PendingTaskManager.getPendingTaskManagerId() |
Modifier and Type | Method and Description |
---|---|
Map<PendingTaskManagerId,Map<JobID,ResourceCounter>> |
ResourceAllocationResult.getAllocationsOnPendingResources() |
Modifier and Type | Method and Description |
---|---|
ResourceAllocationResult.Builder |
ResourceAllocationResult.Builder.addAllocationOnPendingResource(JobID jobId,
PendingTaskManagerId pendingTaskManagerId,
ResourceProfile resourceProfile) |
Map<JobID,ResourceCounter> |
FineGrainedTaskManagerTracker.getPendingAllocationsOfPendingTaskManager(PendingTaskManagerId pendingTaskManagerId) |
Map<JobID,ResourceCounter> |
FineGrainedTaskManagerTracker.removePendingTaskManager(PendingTaskManagerId pendingTaskManagerId) |
Modifier and Type | Method and Description |
---|---|
void |
FineGrainedTaskManagerTracker.replaceAllPendingAllocations(Map<PendingTaskManagerId,Map<JobID,ResourceCounter>> pendingSlotAllocations) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.