|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerUtils
@InterfaceAudience.Private @InterfaceStability.Unstable public class SchedulerUtils
Utilities shared by schedulers.
Field Summary | |
---|---|
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 Summary | |
---|---|
SchedulerUtils()
|
Method Summary | |
---|---|
static org.apache.hadoop.yarn.api.records.ContainerStatus |
createAbnormalContainerStatus(org.apache.hadoop.yarn.api.records.ContainerId containerId,
String diagnostics)
Utility to create a ContainerStatus during exceptional
circumstances. |
static org.apache.hadoop.yarn.api.records.ContainerStatus |
createPreemptedContainerStatus(org.apache.hadoop.yarn.api.records.ContainerId containerId,
String diagnostics)
Utility to create a ContainerStatus during exceptional
circumstances. |
static void |
normalizeRequest(org.apache.hadoop.yarn.api.records.ResourceRequest ask,
org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource minimumResource,
org.apache.hadoop.yarn.api.records.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(org.apache.hadoop.yarn.api.records.ResourceRequest ask,
org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource minimumResource,
org.apache.hadoop.yarn.api.records.Resource maximumResource,
org.apache.hadoop.yarn.api.records.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<org.apache.hadoop.yarn.api.records.ResourceRequest> asks,
org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource minimumResource,
org.apache.hadoop.yarn.api.records.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<org.apache.hadoop.yarn.api.records.ResourceRequest> asks,
org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource minimumResource,
org.apache.hadoop.yarn.api.records.Resource maximumResource,
org.apache.hadoop.yarn.api.records.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(org.apache.hadoop.yarn.api.records.ResourceRequest resReq,
org.apache.hadoop.yarn.api.records.Resource maximumResource)
Utility method to validate a resource request, by insuring that the requested memory/vcore is non-negative and not greater than max |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
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
Constructor Detail |
---|
public SchedulerUtils()
Method Detail |
---|
public static org.apache.hadoop.yarn.api.records.ContainerStatus createAbnormalContainerStatus(org.apache.hadoop.yarn.api.records.ContainerId containerId, String diagnostics)
ContainerStatus
during exceptional
circumstances.
containerId
- ContainerId
of returned/released/lost container.diagnostics
- diagnostic message
ContainerStatus
for an returned/released/lost
containerpublic static org.apache.hadoop.yarn.api.records.ContainerStatus createPreemptedContainerStatus(org.apache.hadoop.yarn.api.records.ContainerId containerId, String diagnostics)
ContainerStatus
during exceptional
circumstances.
containerId
- ContainerId
of returned/released/lost container.diagnostics
- diagnostic message
ContainerStatus
for an returned/released/lost
containerpublic static void normalizeRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> asks, org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource minimumResource, org.apache.hadoop.yarn.api.records.Resource maximumResource)
public static void normalizeRequest(org.apache.hadoop.yarn.api.records.ResourceRequest ask, org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource minimumResource, org.apache.hadoop.yarn.api.records.Resource maximumResource)
public static void normalizeRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> asks, org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource minimumResource, org.apache.hadoop.yarn.api.records.Resource maximumResource, org.apache.hadoop.yarn.api.records.Resource incrementResource)
public static void normalizeRequest(org.apache.hadoop.yarn.api.records.ResourceRequest ask, org.apache.hadoop.yarn.util.resource.ResourceCalculator resourceCalculator, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource minimumResource, org.apache.hadoop.yarn.api.records.Resource maximumResource, org.apache.hadoop.yarn.api.records.Resource incrementResource)
public static void validateResourceRequest(org.apache.hadoop.yarn.api.records.ResourceRequest resReq, org.apache.hadoop.yarn.api.records.Resource maximumResource) throws org.apache.hadoop.yarn.exceptions.InvalidResourceRequestException
InvalidResourceRequestException
- when there is invalid
request
org.apache.hadoop.yarn.exceptions.InvalidResourceRequestException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |