Modifier and Type | Field and Description |
---|---|
static ResourceProfile |
ResourceProfile.ANY
A ResourceProfile that indicates infinite resource that matches any resource requirement.
|
static ResourceProfile |
ResourceProfile.UNKNOWN
A ResourceProfile that indicates an unknown resource requirement.
|
static ResourceProfile |
ResourceProfile.ZERO
A ResourceProfile describing zero resources.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
ResourceProfile.Builder.build() |
static ResourceProfile |
ResourceProfile.fromResources(double cpuCores,
int taskHeapMemoryMB) |
static ResourceProfile |
ResourceProfile.fromResourceSpec(ResourceSpec resourceSpec,
MemorySize networkMemory) |
ResourceProfile |
ResourceBudgetManager.getAvailableBudget() |
ResourceProfile |
SlotProfile.getPhysicalSlotResourceProfile()
Returns the desired resource profile for the physical slot to host this task slot.
|
ResourceProfile |
SlotProfile.getTaskResourceProfile()
Returns the desired resource profile for the task slot.
|
ResourceProfile |
ResourceBudgetManager.getTotalBudget() |
ResourceProfile |
ResourceProfile.merge(ResourceProfile other)
Calculates the sum of two resource profiles.
|
ResourceProfile |
ResourceProfile.multiply(int multiplier) |
ResourceProfile |
ResourceProfile.subtract(ResourceProfile other)
Subtracts another piece of resource profile from this one.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ResourceProfile.allFieldsNoLessThan(ResourceProfile other)
Check whether all fields of this resource profile are no less than the given resource
profile.
|
boolean |
ResourceProfile.isMatching(ResourceProfile required)
Check whether required resource profile can be matched.
|
ResourceProfile |
ResourceProfile.merge(ResourceProfile other)
Calculates the sum of two resource profiles.
|
static ResourceProfile.Builder |
ResourceProfile.newBuilder(ResourceProfile resourceProfile) |
static SlotProfile |
SlotProfile.priorAllocation(ResourceProfile taskResourceProfile,
ResourceProfile physicalSlotResourceProfile,
Collection<TaskManagerLocation> preferredLocations,
Collection<AllocationID> priorAllocations,
Set<AllocationID> reservedAllocations)
Returns a slot profile for the given resource profile, prior allocations and all prior
allocation ids from the whole execution graph.
|
boolean |
ResourceBudgetManager.release(ResourceProfile reservation) |
boolean |
ResourceBudgetManager.reserve(ResourceProfile reservation) |
ResourceProfile |
ResourceProfile.subtract(ResourceProfile other)
Subtracts another piece of resource profile from this one.
|
Constructor and Description |
---|
ResourceBudgetManager(ResourceProfile totalBudget) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
ArchivedExecutionJobVertex.getResourceProfile() |
ResourceProfile |
ExecutionVertex.getResourceProfile() |
ResourceProfile |
ExecutionJobVertex.getResourceProfile() |
ResourceProfile |
AccessExecutionJobVertex.getResourceProfile()
Returns the resource profile for this job vertex.
|
Constructor and Description |
---|
ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices,
JobVertexID id,
String name,
int parallelism,
int maxParallelism,
ResourceProfile resourceProfile,
StringifiedAccumulatorResult[] archivedUserAccumulators) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotSharingGroup.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
void |
SlotSharingGroup.setResourceProfile(ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotInfo.getResourceProfile()
Returns the resource profile of the slot.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotSelectionStrategy.SlotInfoAndResources.getRemainingResources() |
ResourceProfile |
SlotInfoWithUtilization.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
Collection<ResourceProfile> |
PhysicalSlotRequestBulk.getPendingRequests()
Returns
ResourceProfile s of pending physical slot requests. |
Modifier and Type | Method and Description |
---|---|
Optional<PhysicalSlot> |
SlotPool.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID,
ResourceProfile requirementProfile)
Allocates the available slot with the given allocation id under the given request id for the
given requirement profile.
|
Optional<PhysicalSlot> |
DeclarativeSlotPoolBridge.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID,
ResourceProfile requirementProfile) |
default CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile)
Requests the allocation of a new batch slot from the resource manager.
|
CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Collection<AllocationID> preferredAllocations) |
CompletableFuture<PhysicalSlot> |
DeclarativeSlotPoolBridge.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Collection<AllocationID> preferredAllocations) |
CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Collection<AllocationID> preferredAllocations,
Time timeout)
Request the allocation of a new slot from the resource manager.
|
CompletableFuture<PhysicalSlot> |
DeclarativeSlotPoolBridge.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Collection<AllocationID> preferredAllocations,
Time timeout) |
default CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Time timeout)
Request the allocation of a new slot from the resource manager.
|
PhysicalSlot |
DeclarativeSlotPool.reserveFreeSlot(AllocationID allocationId,
ResourceProfile requiredSlotProfile)
Reserves the free slot identified by the given allocationId and maps it to the given
requiredSlotProfile.
|
PhysicalSlot |
DefaultDeclarativeSlotPool.reserveFreeSlot(AllocationID allocationId,
ResourceProfile requiredSlotProfile) |
protected abstract Optional<SlotSelectionStrategy.SlotInfoAndLocality> |
LocationPreferenceSlotSelectionStrategy.selectWithoutLocationPreference(Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots,
ResourceProfile resourceProfile) |
Constructor and Description |
---|
SlotInfoAndResources(SlotInfo slotInfo,
ResourceProfile remainingResources,
double taskExecutorUtilization) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
TaskExecutorRegistration.getDefaultSlotResourceProfile() |
ResourceProfile |
ResourceOverview.getFreeResource() |
ResourceProfile |
ResourceOverview.getTotalResource() |
ResourceProfile |
TaskExecutorRegistration.getTotalResourceProfile() |
Modifier and Type | Method and Description |
---|---|
static WorkerResourceSpec |
WorkerResourceSpec.fromTotalResourceProfile(ResourceProfile resourceProfile,
int numSlots) |
Constructor and Description |
---|
ResourceOverview(int numberTaskManagers,
int numberRegisteredSlots,
int numberFreeSlots,
int numberBlockedTaskManagers,
int numberBlockedFreeSlots,
ResourceProfile totalResource,
ResourceProfile freeResource) |
TaskExecutorRegistration(String taskExecutorAddress,
ResourceID resourceId,
int dataPort,
int jmxPort,
HardwareDescription hardwareDescription,
TaskExecutorMemoryConfiguration memoryConfiguration,
ResourceProfile defaultSlotResourceProfile,
ResourceProfile totalResourceProfile,
String nodeId) |
Constructor and Description |
---|
UnfulfillableSlotRequestException(AllocationID allocationId,
ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
WorkerRegistration.getDefaultSlotResourceProfile() |
ResourceProfile |
WorkerRegistration.getTotalResourceProfile() |
Constructor and Description |
---|
WorkerRegistration(TaskExecutorGateway taskExecutorGateway,
WorkerType worker,
int dataPort,
int jmxPort,
HardwareDescription hardwareDescription,
TaskExecutorMemoryConfiguration memoryConfiguration,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile,
String nodeId) |
Modifier and Type | Method and Description |
---|---|
static ResourceProfile |
SlotManagerUtils.generateDefaultSlotResourceProfile(ResourceProfile resourceProfile,
int numSlotsPerWorker)
|
static ResourceProfile |
SlotManagerUtils.generateDefaultSlotResourceProfile(WorkerResourceSpec workerResourceSpec,
int numSlotsPerWorker)
|
static ResourceProfile |
SlotManagerUtils.generateTaskManagerTotalResourceProfile(WorkerResourceSpec workerResourceSpec) |
ResourceProfile |
FineGrainedTaskManagerRegistration.getAvailableResource() |
ResourceProfile |
TaskManagerInfo.getAvailableResource()
Get the available resource.
|
ResourceProfile |
FineGrainedTaskManagerRegistration.getDefaultSlotResourceProfile() |
ResourceProfile |
TaskManagerInfo.getDefaultSlotResourceProfile()
Get the default slot resource profile.
|
ResourceProfile |
TaskManagerRegistration.getDefaultSlotResourceProfile() |
ResourceProfile |
PendingTaskManager.getDefaultSlotResourceProfile() |
static ResourceProfile |
SlotManagerUtils.getEffectiveResourceProfile(ResourceProfile requirement,
ResourceProfile defaultResourceProfile) |
ResourceProfile |
SlotManager.getFreeResource() |
ResourceProfile |
DeclarativeSlotManager.getFreeResource() |
ResourceProfile |
FineGrainedTaskManagerTracker.getFreeResource() |
ResourceProfile |
FineGrainedSlotManager.getFreeResource() |
ResourceProfile |
ClusterResourceStatisticsProvider.getFreeResource()
Get profile of total free resources.
|
ResourceProfile |
SlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
DeclarativeSlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
FineGrainedTaskManagerTracker.getFreeResourceOf(InstanceID instanceId) |
ResourceProfile |
FineGrainedSlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
ClusterResourceStatisticsProvider.getFreeResourceOf(InstanceID instanceId)
Get profile of free resources from the TaskManager with the given instance id.
|
ResourceProfile |
FineGrainedTaskManagerTracker.getPendingResource() |
ResourceProfile |
ClusterResourceStatisticsProvider.getPendingResource()
Get profile of total pending resources.
|
ResourceProfile |
SlotManager.getRegisteredResource() |
ResourceProfile |
DeclarativeSlotManager.getRegisteredResource() |
ResourceProfile |
FineGrainedTaskManagerTracker.getRegisteredResource() |
ResourceProfile |
FineGrainedSlotManager.getRegisteredResource() |
ResourceProfile |
ClusterResourceStatisticsProvider.getRegisteredResource()
Get profile of total registered resources.
|
ResourceProfile |
SlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
DeclarativeSlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
FineGrainedTaskManagerTracker.getRegisteredResourceOf(InstanceID instanceId) |
ResourceProfile |
FineGrainedSlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
ClusterResourceStatisticsProvider.getRegisteredResourceOf(InstanceID instanceId)
Get profile of registered resources from the TaskManager with the given instance id.
|
ResourceProfile |
TaskManagerSlotInformation.getResourceProfile()
Get resource profile of this slot.
|
ResourceProfile |
FineGrainedTaskManagerSlot.getResourceProfile() |
ResourceProfile |
PendingTaskManagerSlot.getResourceProfile() |
ResourceProfile |
FineGrainedTaskManagerRegistration.getTotalResource() |
ResourceProfile |
TaskManagerInfo.getTotalResource()
Get the total resource.
|
ResourceProfile |
TaskManagerRegistration.getTotalResource() |
ResourceProfile |
PendingTaskManager.getTotalResourceProfile() |
Modifier and Type | Method and Description |
---|---|
ResourceAllocationResult.Builder |
ResourceAllocationResult.Builder.addAllocationOnPendingResource(JobID jobId,
PendingTaskManagerId pendingTaskManagerId,
ResourceProfile resourceProfile) |
ResourceAllocationResult.Builder |
ResourceAllocationResult.Builder.addAllocationOnRegisteredResource(JobID jobId,
InstanceID instanceId,
ResourceProfile resourceProfile) |
void |
DefaultSlotTracker.addSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
JobID assignedJob) |
void |
FineGrainedTaskManagerTracker.addTaskManager(TaskExecutorConnection taskExecutorConnection,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile) |
CompletableFuture<Void> |
SlotStatusSyncer.allocateSlot(InstanceID instanceId,
JobID jobId,
String targetAddress,
ResourceProfile resourceProfile)
Allocate a slot from the task manager.
|
CompletableFuture<Void> |
DefaultSlotStatusSyncer.allocateSlot(InstanceID instanceId,
JobID jobId,
String targetAddress,
ResourceProfile resourceProfile) |
static int |
SlotManagerUtils.calculateDefaultNumSlots(ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile) |
<T extends TaskManagerSlotInformation> |
AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
<T extends TaskManagerSlotInformation> |
SlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
Finds a matching slot for the requested
ResourceProfile given the collection of free
slots and the total number of slots per TaskExecutor. |
<T extends TaskManagerSlotInformation> |
LeastUtilizationSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
static ResourceProfile |
SlotManagerUtils.generateDefaultSlotResourceProfile(ResourceProfile resourceProfile,
int numSlotsPerWorker)
|
static ResourceProfile |
SlotManagerUtils.getEffectiveResourceProfile(ResourceProfile requirement,
ResourceProfile defaultResourceProfile) |
Collection<PendingTaskManager> |
FineGrainedTaskManagerTracker.getPendingTaskManagersByTotalAndDefaultSlotResourceProfile(ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile) |
default boolean |
TaskManagerSlotInformation.isMatchingRequirement(ResourceProfile required)
Returns true if the required
ResourceProfile can be fulfilled by this slot. |
void |
ResourceTracker.notifyAcquiredResource(JobID jobId,
ResourceProfile resourceProfile)
Notifies the tracker about the acquisition of a resource with the given resource profile, for
the given job.
|
void |
DefaultResourceTracker.notifyAcquiredResource(JobID jobId,
ResourceProfile resourceProfile) |
void |
ResourceTracker.notifyLostResource(JobID jobId,
ResourceProfile resourceProfile)
Notifies the tracker about the loss of a resource with the given resource profile, for the
given job.
|
void |
DefaultResourceTracker.notifyLostResource(JobID jobId,
ResourceProfile resourceProfile) |
void |
FineGrainedTaskManagerTracker.notifySlotStatus(AllocationID allocationId,
JobID jobId,
InstanceID instanceId,
ResourceProfile resourceProfile,
org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState) |
boolean |
SlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile)
Registers a new task manager at the slot manager.
|
boolean |
DeclarativeSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile)
Registers a new task manager at the slot manager.
|
boolean |
FineGrainedSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile)
Registers a new task manager at the slot manager.
|
Constructor and Description |
---|
DefaultResourceAllocationStrategy(ResourceProfile totalResourceProfile,
int numSlotsPerWorker) |
FineGrainedTaskManagerRegistration(TaskExecutorConnection taskManagerConnection,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile) |
FineGrainedTaskManagerSlot(AllocationID allocationId,
JobID jobId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState) |
PendingTaskManager(ResourceProfile totalResourceProfile,
int numSlots) |
PendingTaskManagerSlot(ResourceProfile resourceProfile) |
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection,
Collection<SlotID> slots,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile) |
Modifier and Type | Method and Description |
---|---|
static ResourceProfileInfo |
ResourceProfileInfo.fromResrouceProfile(ResourceProfile resourceProfile) |
Constructor and Description |
---|
SlotInfo(JobID jobId,
ResourceProfile resource) |
TaskManagerInfo(ResourceID resourceId,
String address,
int dataPort,
int jmxPort,
long lastHeartbeat,
int numberSlots,
int numberAvailableSlots,
ResourceProfile totalResource,
ResourceProfile freeResource,
HardwareDescription hardwareDescription,
TaskExecutorMemoryConfiguration memoryConfiguration,
Boolean blocked) |
Modifier and Type | Method and Description |
---|---|
PhysicalSlot |
ReserveSlotFunction.reserveSlot(AllocationID allocationId,
ResourceProfile resourceProfile)
Reserves the slot identified by the given allocation ID for the given resource profile.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
ResourceRequirement.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
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.
|
Optional<ResourceProfile> |
DefaultRequirementMatcher.match(ResourceProfile resourceProfile,
ResourceCounter totalRequirements,
java.util.function.Function<ResourceProfile,Integer> numAssignedResourcesLookup) |
Modifier and Type | Method and Description |
---|---|
static ResourceRequirement |
ResourceRequirement.create(ResourceProfile resourceProfile,
int numberOfRequiredSlots) |
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.
|
Optional<ResourceProfile> |
DefaultRequirementMatcher.match(ResourceProfile resourceProfile,
ResourceCounter totalRequirements,
java.util.function.Function<ResourceProfile,Integer> numAssignedResourcesLookup) |
Modifier and Type | Method and Description |
---|---|
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.
|
Optional<ResourceProfile> |
DefaultRequirementMatcher.match(ResourceProfile resourceProfile,
ResourceCounter totalRequirements,
java.util.function.Function<ResourceProfile,Integer> numAssignedResourcesLookup) |
Modifier and Type | Method and Description |
---|---|
static ResourceProfile |
TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(TaskExecutorResourceSpec taskExecutorResourceSpec,
int numberOfSlots)
|
static ResourceProfile |
TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(TaskExecutorResourceSpec taskExecutorResourceSpec) |
ResourceProfile |
TaskManagerConfiguration.getDefaultSlotResourceProfile() |
ResourceProfile |
SlotStatus.getResourceProfile()
Get the resource profile of this slot.
|
ResourceProfile |
TaskManagerConfiguration.getTotalResourceProfile() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout)
Requests a slot from the TaskManager.
|
Constructor and Description |
---|
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile) |
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile,
JobID jobID,
AllocationID allocationID) |
TaskManagerConfiguration(int numberSlots,
ResourceProfile defaultSlotResourceProfile,
ResourceProfile totalResourceProfile,
String[] tmpDirectories,
Time rpcTimeout,
Time slotTimeout,
java.time.Duration maxRegistrationDuration,
Configuration configuration,
boolean exitJvmOnOutOfMemory,
String taskManagerLogPath,
String taskManagerStdoutPath,
String taskManagerLogDir,
String taskManagerExternalAddress,
File tmpWorkingDirectory,
RetryingRegistrationConfiguration retryingRegistrationConfiguration) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotOffer.getResourceProfile() |
ResourceProfile |
TaskSlot.getResourceProfile() |
ResourceProfile |
SlotAllocationSnapshot.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
boolean |
TaskSlotTable.allocateSlot(int index,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
Time slotTimeout)
Allocate the slot with the given index for the given job and allocation id.
|
boolean |
TaskSlotTableImpl.allocateSlot(int requestedIndex,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
Time slotTimeout) |
Constructor and Description |
---|
SlotAllocationSnapshot(SlotID slotID,
JobID jobId,
String jobTargetAddress,
AllocationID allocationId,
ResourceProfile resourceProfile) |
SlotOffer(AllocationID allocationID,
int index,
ResourceProfile resourceProfile) |
TaskSlot(int index,
ResourceProfile resourceProfile,
int memoryPageSize,
JobID jobId,
AllocationID allocationId,
Executor asyncExecutor) |
TaskSlotTableImpl(int numberSlots,
ResourceProfile totalAvailableResourceProfile,
ResourceProfile defaultSlotResourceProfile,
int memoryPageSize,
TimerService<AllocationID> timerService,
Executor memoryVerificationExecutor) |
Modifier and Type | Method and Description |
---|---|
Set<ResourceProfile> |
ResourceCounter.getResources()
Gets all stored
ResourceProfiles . |
Collection<Map.Entry<ResourceProfile,Integer>> |
ResourceCounter.getResourcesWithCount()
Gets the stored resources and their counts.
|
Modifier and Type | Method and Description |
---|---|
ResourceCounter |
ResourceCounter.add(ResourceProfile resourceProfile,
int increment)
Adds increment to the count of resourceProfile and returns the new value.
|
boolean |
ResourceCounter.containsResource(ResourceProfile resourceProfile)
Checks whether resourceProfile is contained in this counter.
|
int |
ResourceCounter.getResourceCount(ResourceProfile resourceProfile)
Number of resources with the given
ResourceProfile . |
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.
|
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.subtract(Map<ResourceProfile,Integer> decrement)
Subtracts decrement from this resource counter value and returns the new value.
|
static ResourceCounter |
ResourceCounter.withResources(Map<ResourceProfile,Integer> resources)
Creates a resource counter with the specified set of resources.
|
Modifier and Type | Method and Description |
---|---|
Optional<ResourceProfile> |
StreamGraph.getSlotSharingGroupResource(String groupId) |
Modifier and Type | Method and Description |
---|---|
StreamGraphGenerator |
StreamGraphGenerator.setSlotSharingGroupResource(Map<String,ResourceProfile> slotSharingGroupResources)
Specify fine-grained resource requirements for slot sharing groups.
|
void |
StreamGraph.setSlotSharingGroupResource(Map<String,ResourceProfile> slotSharingGroupResources) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.