public interface ResourceAllocationStrategy
|Modifier and Type||Method and Description|
Try to make an allocation decision to fulfill the resource requirements.
ResourceAllocationResult tryFulfillRequirements(Map<JobID,Collection<ResourceRequirement>> missingResources, org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerResourceInfoProvider taskManagerResourceInfoProvider)
Notice: For performance considerations, modifications might be performed directly on the input arguments. If the arguments are reused elsewhere, please make a deep copy in advance.
missingResources- resource requirements that are not yet fulfilled, indexed by jobId
taskManagerResourceInfoProvider- provide the registered/pending resources of the current cluster
ResourceAllocationResultbased on the current status, which contains whether the requirements can be fulfilled and the actions to take
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.