org.apache.hadoop.yarn.server.resourcemanager
Class RMServerUtils

java.lang.Object
  extended by 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


Constructor Summary
RMServerUtils()
           
 
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
 

Constructor Detail

RMServerUtils

public RMServerUtils()
Method Detail

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.