org.apache.hadoop.yarn.server.resourcemanager
Class RMServerUtils
java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.RMServerUtils
public class RMServerUtils
- extends Object
Utility methods to aid serving RM data through the REST and RPC APIs
Method Summary |
static List<RMNode> |
queryRMNodes(RMContext context,
EnumSet<org.apache.hadoop.yarn.api.records.NodeState> acceptedStates)
|
static void |
validateBlacklistRequest(org.apache.hadoop.yarn.api.records.ResourceBlacklistRequest blacklistRequest)
|
static void |
validateContainerReleaseRequest(List<org.apache.hadoop.yarn.api.records.ContainerId> containerReleaseList,
org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
It will validate to make sure all the containers belong to correct
application attempt id. |
static void |
validateResourceRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> ask,
org.apache.hadoop.yarn.api.records.Resource maximumResource)
Utility method to validate a list resource requests, 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 |
RMServerUtils
public RMServerUtils()
queryRMNodes
public static List<RMNode> queryRMNodes(RMContext context,
EnumSet<org.apache.hadoop.yarn.api.records.NodeState> acceptedStates)
validateResourceRequests
public static void validateResourceRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> ask,
org.apache.hadoop.yarn.api.records.Resource maximumResource)
throws org.apache.hadoop.yarn.exceptions.InvalidResourceRequestException
- Utility method to validate a list resource requests, by insuring that the
requested memory/vcore is non-negative and not greater than max
- Throws:
org.apache.hadoop.yarn.exceptions.InvalidResourceRequestException
validateBlacklistRequest
public static void validateBlacklistRequest(org.apache.hadoop.yarn.api.records.ResourceBlacklistRequest blacklistRequest)
throws org.apache.hadoop.yarn.exceptions.InvalidResourceBlacklistRequestException
- Throws:
org.apache.hadoop.yarn.exceptions.InvalidResourceBlacklistRequestException
validateContainerReleaseRequest
public static void validateContainerReleaseRequest(List<org.apache.hadoop.yarn.api.records.ContainerId> containerReleaseList,
org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
throws org.apache.hadoop.yarn.exceptions.InvalidContainerReleaseException
- It will validate to make sure all the containers belong to correct
application attempt id. If not then it will throw
InvalidContainerReleaseException
- Parameters:
containerReleaseList
- containers to be released as requested by
application master.appAttemptId
- Application attempt Id
- Throws:
org.apache.hadoop.yarn.exceptions.InvalidContainerReleaseException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.