Modifier and Type | Method and Description |
---|---|
ResourceCounter |
DefaultDeclarativeSlotPool.freeReservedSlot(AllocationID allocationId,
Throwable cause,
long currentTime) |
ResourceCounter |
DeclarativeSlotPool.freeReservedSlot(AllocationID allocationId,
Throwable cause,
long currentTime)
Frees the reserved slot identified by the given allocationId.
|
ResourceCounter |
DefaultDeclarativeSlotPool.releaseSlot(AllocationID allocationId,
Exception cause) |
ResourceCounter |
DeclarativeSlotPool.releaseSlot(AllocationID allocationId,
Exception cause)
Releases the slot specified by allocationId if one exists.
|
ResourceCounter |
DefaultDeclarativeSlotPool.releaseSlots(ResourceID owner,
Exception cause) |
ResourceCounter |
DeclarativeSlotPool.releaseSlots(ResourceID owner,
Exception cause)
Releases all slots belonging to the owning TaskExecutor if it has been registered.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultDeclarativeSlotPool.decreaseResourceRequirementsBy(ResourceCounter decrement) |
void |
DeclarativeSlotPool.decreaseResourceRequirementsBy(ResourceCounter decrement)
Decreases the resource requirements by decrement.
|
void |
DefaultDeclarativeSlotPool.increaseResourceRequirementsBy(ResourceCounter increment) |
void |
DeclarativeSlotPool.increaseResourceRequirementsBy(ResourceCounter increment)
Increases the resource requirements by increment.
|
protected void |
DeclarativeSlotPoolBridge.onFailAllocation(ResourceCounter previouslyFulfilledRequirements) |
protected void |
DeclarativeSlotPoolService.onFailAllocation(ResourceCounter previouslyFulfilledRequirements)
This method is called when an allocation fails.
|
protected void |
DeclarativeSlotPoolBridge.onReleaseTaskManager(ResourceCounter previouslyFulfilledRequirement) |
protected void |
DeclarativeSlotPoolService.onReleaseTaskManager(ResourceCounter previouslyFulfilledRequirement)
This method is called when a TaskManager is released.
|
void |
DefaultDeclarativeSlotPool.setResourceRequirements(ResourceCounter resourceRequirements) |
void |
DeclarativeSlotPool.setResourceRequirements(ResourceCounter resourceRequirements)
Sets the resource requirements to the given resourceRequirements.
|
Modifier and Type | Method and Description |
---|---|
Map<PendingTaskManagerId,Map<JobID,ResourceCounter>> |
ResourceAllocationResult.getAllocationsOnPendingResources() |
Map<JobID,Map<InstanceID,ResourceCounter>> |
ResourceAllocationResult.getAllocationsOnRegisteredResources() |
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) |
Modifier and Type | Method and Description |
---|---|
boolean |
AdaptiveScheduler.hasDesiredResources(ResourceCounter desiredResources) |
Modifier and Type | Method and Description |
---|---|
ResourceCounter |
SlotAllocator.calculateRequiredSlots(Iterable<JobInformation.VertexInformation> vertices)
Calculates the total resources required for scheduling the given vertices.
|
ResourceCounter |
SlotSharingSlotAllocator.calculateRequiredSlots(Iterable<JobInformation.VertexInformation> vertices) |
Modifier and Type | Method and Description |
---|---|
Optional<ResourceProfile> |
DefaultRequirementMatcher.match(ResourceProfile resourceProfile,
ResourceCounter totalRequirements,
java.util.function.Function<ResourceProfile,Integer> numAssignedResourcesLookup) |
Optional<ResourceProfile> |
RequirementMatcher.match(ResourceProfile resourceProfile,
ResourceCounter totalRequirements,
java.util.function.Function<ResourceProfile,Integer> numAssignedResourcesLookup)
Attempts to match the given resource profile with one of the given requirements.
|
Modifier and Type | Method and Description |
---|---|
ResourceCounter |
ResourceCounter.add(Map<ResourceProfile,Integer> increment)
Adds the given increment to this resource counter value and returns the resulting value.
|
ResourceCounter |
ResourceCounter.add(ResourceCounter increment)
Adds increment to this resource counter value and returns the resulting value.
|
ResourceCounter |
ResourceCounter.add(ResourceProfile resourceProfile,
int increment)
Adds increment to the count of resourceProfile and returns the new value.
|
static ResourceCounter |
ResourceCounter.empty()
Creates an empty resource counter.
|
ResourceCounter |
ResourceCounter.subtract(Map<ResourceProfile,Integer> decrement)
Subtracts decrement from this resource counter value and returns the new value.
|
ResourceCounter |
ResourceCounter.subtract(ResourceCounter decrement)
Subtracts decrement from this resource counter value and returns the new value.
|
ResourceCounter |
ResourceCounter.subtract(ResourceProfile resourceProfile,
int decrement)
Subtracts decrement from the count of the given resourceProfile and returns the new value.
|
static ResourceCounter |
ResourceCounter.withResource(ResourceProfile resourceProfile,
int count)
Creates a resource counter with the given resourceProfile and its count.
|
static ResourceCounter |
ResourceCounter.withResources(Map<ResourceProfile,Integer> resources)
Creates a resource counter with the specified set of resources.
|
Modifier and Type | Method and Description |
---|---|
ResourceCounter |
ResourceCounter.add(ResourceCounter increment)
Adds increment to this resource counter value and returns the resulting value.
|
ResourceCounter |
ResourceCounter.subtract(ResourceCounter decrement)
Subtracts decrement from this resource counter value and returns the new value.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.