@InterfaceAudience.Private @InterfaceStability.Unstable public class SchedulerUtils extends Object
Modifier and Type | Field and Description |
---|---|
static String |
COMPLETED_APPLICATION |
static String |
EXPIRED_CONTAINER |
static String |
LOST_CONTAINER |
static String |
PREEMPTED_CONTAINER |
static String |
RELEASED_CONTAINER |
static String |
UNRESERVED_CONTAINER |
Constructor and Description |
---|
SchedulerUtils() |
Modifier and Type | Method and Description |
---|---|
static ContainerStatus |
createAbnormalContainerStatus(ContainerId containerId,
String diagnostics)
Utility to create a
ContainerStatus during exceptional
circumstances. |
static ContainerStatus |
createPreemptedContainerStatus(ContainerId containerId,
String diagnostics)
Utility to create a
ContainerStatus during exceptional
circumstances. |
static void |
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 |
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 |
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 |
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.
|
static void |
validateResourceRequest(ResourceRequest resReq,
Resource maximumResource)
Utility method to validate a resource request, by insuring that the
requested memory/vcore is non-negative and not greater than max
|
public static final String RELEASED_CONTAINER
public static final String LOST_CONTAINER
public static final String PREEMPTED_CONTAINER
public static final String COMPLETED_APPLICATION
public static final String EXPIRED_CONTAINER
public static final String UNRESERVED_CONTAINER
public static ContainerStatus createAbnormalContainerStatus(ContainerId containerId, String diagnostics)
ContainerStatus
during exceptional
circumstances.containerId
- ContainerId
of returned/released/lost container.diagnostics
- diagnostic messageContainerStatus
for an returned/released/lost
containerpublic static ContainerStatus createPreemptedContainerStatus(ContainerId containerId, String diagnostics)
ContainerStatus
during exceptional
circumstances.containerId
- ContainerId
of returned/released/lost container.diagnostics
- diagnostic messageContainerStatus
for an returned/released/lost
containerpublic static void normalizeRequests(List<ResourceRequest> asks, ResourceCalculator resourceCalculator, Resource clusterResource, Resource minimumResource, Resource maximumResource)
public static void normalizeRequest(ResourceRequest ask, ResourceCalculator resourceCalculator, Resource clusterResource, Resource minimumResource, Resource maximumResource)
public static void normalizeRequests(List<ResourceRequest> asks, ResourceCalculator resourceCalculator, Resource clusterResource, Resource minimumResource, Resource maximumResource, Resource incrementResource)
public static void normalizeRequest(ResourceRequest ask, ResourceCalculator resourceCalculator, Resource clusterResource, Resource minimumResource, Resource maximumResource, Resource incrementResource)
public static void validateResourceRequest(ResourceRequest resReq, Resource maximumResource) throws InvalidResourceRequestException
InvalidResourceRequestException
- when there is invalid
requestInvalidResourceRequestException
Copyright © 2013 Apache Software Foundation. All rights reserved.