Modifier and Type | Method and Description |
---|---|
static void |
SchedulerUtils.normalizeRequest(ResourceRequest ask,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource)
Utility method to normalize a resource request, by insuring that the
requested memory is a multiple of minMemory and is not zero.
|
static void |
SchedulerUtils.normalizeRequest(ResourceRequest ask,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource,
Resource incrementResource)
Utility method to normalize a resource request, by insuring that the
requested memory is a multiple of minMemory and is not zero.
|
static void |
SchedulerUtils.normalizeRequests(List<ResourceRequest> asks,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource)
Utility method to normalize a list of resource requests, by insuring that
the memory for each request is a multiple of minMemory and is not zero.
|
static void |
SchedulerUtils.normalizeRequests(List<ResourceRequest> asks,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource,
Resource incrementResource)
Utility method to normalize a list of resource requests, by insuring that
the memory for each request is a multiple of minMemory and is not zero.
|
Modifier and Type | Field and Description |
---|---|
static Class<? extends ResourceCalculator> |
CapacitySchedulerConfiguration.DEFAULT_RESOURCE_CALCULATOR_CLASS |
Modifier and Type | Method and Description |
---|---|
ResourceCalculator |
CapacitySchedulerConfiguration.getResourceCalculator() |
ResourceCalculator |
CapacitySchedulerContext.getResourceCalculator() |
ResourceCalculator |
CapacityScheduler.getResourceCalculator() |
Modifier and Type | Method and Description |
---|---|
void |
CapacitySchedulerConfiguration.setResourceComparator(Class<? extends ResourceCalculator> resourceCalculatorClass) |
Modifier and Type | Method and Description |
---|---|
Allocation |
FiCaSchedulerApp.getAllocation(ResourceCalculator rc,
Resource clusterResource,
Resource minimumAllocation)
This method produces an Allocation that includes the current view
of the resources that will be allocated to and preempted from this
application.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultResourceCalculator |
class |
DominantResourceCalculator
A
ResourceCalculator which uses the concept of
dominant resource to compare multi-dimensional resources. |
Modifier and Type | Method and Description |
---|---|
static float |
Resources.divide(ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource lhs,
Resource rhs) |
static Resource |
Resources.divideAndCeil(ResourceCalculator resourceCalculator,
Resource lhs,
int rhs) |
static boolean |
Resources.greaterThan(ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource lhs,
Resource rhs) |
static boolean |
Resources.greaterThanOrEqual(ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource lhs,
Resource rhs) |
static boolean |
Resources.lessThan(ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource lhs,
Resource rhs) |
static boolean |
Resources.lessThanOrEqual(ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource lhs,
Resource rhs) |
static Resource |
Resources.max(ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource lhs,
Resource rhs) |
static Resource |
Resources.min(ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource lhs,
Resource rhs) |
static Resource |
Resources.multiplyAndNormalizeDown(ResourceCalculator calculator,
Resource lhs,
double by,
Resource factor) |
static Resource |
Resources.multiplyAndNormalizeUp(ResourceCalculator calculator,
Resource lhs,
double by,
Resource factor) |
static Resource |
Resources.normalize(ResourceCalculator calculator,
Resource lhs,
Resource min,
Resource max,
Resource increment) |
static float |
Resources.ratio(ResourceCalculator resourceCalculator,
Resource lhs,
Resource rhs) |
static Resource |
Resources.roundDown(ResourceCalculator calculator,
Resource lhs,
Resource factor) |
static Resource |
Resources.roundUp(ResourceCalculator calculator,
Resource lhs,
Resource factor) |
Copyright © 2013 Apache Software Foundation. All rights reserved.