Package org.apache.hadoop.mapred

Class ResourceMgrDelegate

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.client.api.YarnClient

org.apache.hadoop.mapred.ResourceMgrDelegate

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service

public class ResourceMgrDelegate
extends org.apache.hadoop.yarn.client.api.YarnClient

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.hadoop.yarn.client.api.YarnClient	client

Constructor Summary

Constructors

Constructor	Description
ResourceMgrDelegate(org.apache.hadoop.yarn.conf.YarnConfiguration conf)	Delegate responsible for communicating with the Resource Manager's ApplicationClientProtocol.

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.client.api.YarnClientApplication	createApplication()
org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationResponse	createReservation()
org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteResponse	deleteReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest request)
void	failApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
org.apache.hadoop.mapreduce.TaskTrackerInfo[]	getActiveTrackers()
org.apache.hadoop.mapreduce.JobStatus[]	getAllJobs()
List<org.apache.hadoop.yarn.api.records.QueueInfo>	getAllQueues()
org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier>	getAMRMToken(org.apache.hadoop.yarn.api.records.ApplicationId appId)
org.apache.hadoop.yarn.api.records.ApplicationAttemptReport	getApplicationAttemptReport(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
List<org.apache.hadoop.yarn.api.records.ApplicationAttemptReport>	getApplicationAttempts(org.apache.hadoop.yarn.api.records.ApplicationId appId)
org.apache.hadoop.yarn.api.records.ApplicationId	getApplicationId()
org.apache.hadoop.yarn.api.records.ApplicationReport	getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId appId)
List<org.apache.hadoop.yarn.api.records.ApplicationReport>	getApplications()
List<org.apache.hadoop.yarn.api.records.ApplicationReport>	getApplications(EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates)
List<org.apache.hadoop.yarn.api.records.ApplicationReport>	getApplications(Set<String> applicationTypes)
List<org.apache.hadoop.yarn.api.records.ApplicationReport>	getApplications(Set<String> applicationTypes, EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates)
List<org.apache.hadoop.yarn.api.records.ApplicationReport>	getApplications(Set<String> applicationTypes, EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates, Set<String> applicationTags)
List<org.apache.hadoop.yarn.api.records.ApplicationReport>	getApplications(Set<String> queues, Set<String> users, Set<String> applicationTypes, EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates)
Map<org.apache.hadoop.yarn.api.records.NodeAttributeKey,List<org.apache.hadoop.yarn.api.records.NodeToAttributeValue>>	getAttributesToNodes(Set<org.apache.hadoop.yarn.api.records.NodeAttributeKey> attributes)
org.apache.hadoop.mapreduce.TaskTrackerInfo[]	getBlacklistedTrackers()
List<org.apache.hadoop.yarn.api.records.QueueInfo>	getChildQueueInfos(String parent)
org.apache.hadoop.mapreduce.QueueInfo[]	getChildQueues(String parent)
Set<org.apache.hadoop.yarn.api.records.NodeAttributeInfo>	getClusterAttributes()
org.apache.hadoop.mapreduce.ClusterMetrics	getClusterMetrics()
List<org.apache.hadoop.yarn.api.records.NodeLabel>	getClusterNodeLabels()
org.apache.hadoop.yarn.api.records.ContainerReport	getContainerReport(org.apache.hadoop.yarn.api.records.ContainerId containerId)
List<org.apache.hadoop.yarn.api.records.ContainerReport>	getContainers(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId)
org.apache.hadoop.security.token.Token	getDelegationToken(org.apache.hadoop.io.Text renewer)
String	getFilesystemName()
Map<String,Set<org.apache.hadoop.yarn.api.records.NodeId>>	getLabelsToNodes()
Map<String,Set<org.apache.hadoop.yarn.api.records.NodeId>>	getLabelsToNodes(Set<String> labels)
org.apache.hadoop.mapreduce.JobID	getNewJobID()
List<org.apache.hadoop.yarn.api.records.NodeReport>	getNodeReports(org.apache.hadoop.yarn.api.records.NodeState... states)
Map<String,Set<org.apache.hadoop.yarn.api.records.NodeAttribute>>	getNodeToAttributes(Set<String> hostNames)
Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>>	getNodeToLabels()
long	getProtocolVersion(String arg0, long arg1)
org.apache.hadoop.mapreduce.QueueInfo	getQueue(String queueName)
org.apache.hadoop.mapreduce.QueueAclsInfo[]	getQueueAclsForCurrentUser()
List<org.apache.hadoop.yarn.api.records.QueueUserACLInfo>	getQueueAclsInfo()
org.apache.hadoop.yarn.api.records.QueueInfo	getQueueInfo(String queueName)
org.apache.hadoop.yarn.api.records.QueueInfo	getQueueInfo(String queueName, String subClusterId)
org.apache.hadoop.mapreduce.QueueInfo[]	getQueues()
org.apache.hadoop.yarn.api.records.Resource	getResourceProfile(String profile)
Map<String,org.apache.hadoop.yarn.api.records.Resource>	getResourceProfiles()
List<org.apache.hadoop.yarn.api.records.ResourceTypeInfo>	getResourceTypeInfo()
org.apache.hadoop.yarn.api.records.Token	getRMDelegationToken(org.apache.hadoop.io.Text renewer)
org.apache.hadoop.io.Text	getRMDelegationTokenService()
List<org.apache.hadoop.yarn.api.records.QueueInfo>	getRootQueueInfos()
org.apache.hadoop.mapreduce.QueueInfo[]	getRootQueues()
String	getStagingAreaDir()
String	getSystemDir()
long	getTaskTrackerExpiryInterval()
org.apache.hadoop.yarn.api.records.YarnClusterMetrics	getYarnClusterMetrics()
void	killApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
void	killApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId, String diagnostics)
org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse	listReservations(org.apache.hadoop.yarn.api.protocolrecords.ReservationListRequest request)
void	moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.records.ApplicationId appId, String queue)
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	serviceStart()
protected void	serviceStop()
void	setJobPriority(org.apache.hadoop.mapreduce.JobID arg0, String arg1)
void	shellToContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId, org.apache.hadoop.yarn.api.records.ShellContainerCommand command)
void	signalToContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId, org.apache.hadoop.yarn.api.records.SignalContainerCommand command)
org.apache.hadoop.yarn.api.records.ApplicationId	submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appContext)
org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse	submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request)
org.apache.hadoop.yarn.api.records.Priority	updateApplicationPriority(org.apache.hadoop.yarn.api.records.ApplicationId applicationId, org.apache.hadoop.yarn.api.records.Priority priority)
org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse	updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request)

Methods inherited from class org.apache.hadoop.yarn.client.api.YarnClient

createYarnClient, getApplications, updateApplicationTimeouts

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

client

@Private
@VisibleForTesting
protected org.apache.hadoop.yarn.client.api.YarnClient client

Constructor Details

ResourceMgrDelegate

public ResourceMgrDelegate(org.apache.hadoop.yarn.conf.YarnConfiguration conf)

Delegate responsible for communicating with the Resource Manager's ApplicationClientProtocol.

Parameters:

conf - the configuration object.

Method Details

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
                    throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

Throws:

Exception

getActiveTrackers

public org.apache.hadoop.mapreduce.TaskTrackerInfo[] getActiveTrackers()
                                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getAllJobs

public org.apache.hadoop.mapreduce.JobStatus[] getAllJobs()
                                                   throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getBlacklistedTrackers

public org.apache.hadoop.mapreduce.TaskTrackerInfo[] getBlacklistedTrackers()
                                                                     throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getClusterMetrics

public org.apache.hadoop.mapreduce.ClusterMetrics getClusterMetrics()
                                                             throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getRMDelegationTokenService

public org.apache.hadoop.io.Text getRMDelegationTokenService()

getDelegationToken

public org.apache.hadoop.security.token.Token getDelegationToken(org.apache.hadoop.io.Text renewer)
                                                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getFilesystemName

public String getFilesystemName()
                         throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getNewJobID

public org.apache.hadoop.mapreduce.JobID getNewJobID()
                                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getQueue

public org.apache.hadoop.mapreduce.QueueInfo getQueue(String queueName)
                                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getQueueAclsForCurrentUser

public org.apache.hadoop.mapreduce.QueueAclsInfo[] getQueueAclsForCurrentUser()
                                                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getQueues

public org.apache.hadoop.mapreduce.QueueInfo[] getQueues()
                                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getRootQueues

public org.apache.hadoop.mapreduce.QueueInfo[] getRootQueues()
                                                      throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getChildQueues

public org.apache.hadoop.mapreduce.QueueInfo[] getChildQueues(String parent)
                                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getStagingAreaDir

public String getStagingAreaDir()
                         throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getSystemDir

public String getSystemDir()
                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getTaskTrackerExpiryInterval

public long getTaskTrackerExpiryInterval()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

setJobPriority

public void setJobPriority(org.apache.hadoop.mapreduce.JobID arg0,
 String arg1)
                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getProtocolVersion

public long getProtocolVersion(String arg0,
 long arg1)
                        throws IOException

Throws:

IOException

getApplicationId

public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId()

createApplication

public org.apache.hadoop.yarn.client.api.YarnClientApplication createApplication()
                                                                          throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

createApplication in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

submitApplication

public org.apache.hadoop.yarn.api.records.ApplicationId submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appContext)
                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

submitApplication in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

failApplicationAttempt

public void failApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId)
                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

failApplicationAttempt in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

killApplication

public void killApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
                     throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

killApplication in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplicationReport

public org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId appId)
                                                                          throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplicationReport in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getAMRMToken

public org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier> getAMRMToken(org.apache.hadoop.yarn.api.records.ApplicationId appId)
                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getAMRMToken in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplications

public List<org.apache.hadoop.yarn.api.records.ApplicationReport> getApplications()
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplications in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplications

public List<org.apache.hadoop.yarn.api.records.ApplicationReport> getApplications(Set<String> applicationTypes)
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplications in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplications

public List<org.apache.hadoop.yarn.api.records.ApplicationReport> getApplications(EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates)
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplications in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplications

public List<org.apache.hadoop.yarn.api.records.ApplicationReport> getApplications(Set<String> applicationTypes,
 EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates)
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplications in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplications

public List<org.apache.hadoop.yarn.api.records.ApplicationReport> getApplications(Set<String> applicationTypes,
 EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates,
 Set<String> applicationTags)
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplications in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplications

public List<org.apache.hadoop.yarn.api.records.ApplicationReport> getApplications(Set<String> queues,
 Set<String> users,
 Set<String> applicationTypes,
 EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> applicationStates)
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplications in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getYarnClusterMetrics

public org.apache.hadoop.yarn.api.records.YarnClusterMetrics getYarnClusterMetrics()
                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getYarnClusterMetrics in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getNodeReports

public List<org.apache.hadoop.yarn.api.records.NodeReport> getNodeReports(org.apache.hadoop.yarn.api.records.NodeState... states)
                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getNodeReports in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getRMDelegationToken

public org.apache.hadoop.yarn.api.records.Token getRMDelegationToken(org.apache.hadoop.io.Text renewer)
                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getRMDelegationToken in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getQueueInfo

public org.apache.hadoop.yarn.api.records.QueueInfo getQueueInfo(String queueName)
                                                          throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getQueueInfo in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getQueueInfo

public org.apache.hadoop.yarn.api.records.QueueInfo getQueueInfo(String queueName,
 String subClusterId)
                                                          throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getQueueInfo in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getAllQueues

public List<org.apache.hadoop.yarn.api.records.QueueInfo> getAllQueues()
                                                                throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getAllQueues in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getRootQueueInfos

public List<org.apache.hadoop.yarn.api.records.QueueInfo> getRootQueueInfos()
                                                                     throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getRootQueueInfos in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getChildQueueInfos

public List<org.apache.hadoop.yarn.api.records.QueueInfo> getChildQueueInfos(String parent)
                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getChildQueueInfos in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getQueueAclsInfo

public List<org.apache.hadoop.yarn.api.records.QueueUserACLInfo> getQueueAclsInfo()
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getQueueAclsInfo in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplicationAttemptReport

public org.apache.hadoop.yarn.api.records.ApplicationAttemptReport getApplicationAttemptReport(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId)
                                                                                        throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplicationAttemptReport in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplicationAttempts

public List<org.apache.hadoop.yarn.api.records.ApplicationAttemptReport> getApplicationAttempts(org.apache.hadoop.yarn.api.records.ApplicationId appId)
                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getApplicationAttempts in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getContainerReport

public org.apache.hadoop.yarn.api.records.ContainerReport getContainerReport(org.apache.hadoop.yarn.api.records.ContainerId containerId)
                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getContainerReport in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getContainers

public List<org.apache.hadoop.yarn.api.records.ContainerReport> getContainers(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId)
                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getContainers in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

moveApplicationAcrossQueues

public void moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 String queue)
                                 throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

moveApplicationAcrossQueues in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

createReservation

public org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationResponse createReservation()
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

createReservation in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

submitReservation

public org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request)
                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

submitReservation in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

updateReservation

public org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

updateReservation in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deleteReservation

public org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteResponse deleteReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

deleteReservation in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

listReservations

public org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse listReservations(org.apache.hadoop.yarn.api.protocolrecords.ReservationListRequest request)
                                                                                    throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

listReservations in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getNodeToLabels

public Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> getNodeToLabels()
                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getNodeToLabels in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getLabelsToNodes

public Map<String,Set<org.apache.hadoop.yarn.api.records.NodeId>> getLabelsToNodes()
                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getLabelsToNodes in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getLabelsToNodes

public Map<String,Set<org.apache.hadoop.yarn.api.records.NodeId>> getLabelsToNodes(Set<String> labels)
                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getLabelsToNodes in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getClusterNodeLabels

public List<org.apache.hadoop.yarn.api.records.NodeLabel> getClusterNodeLabels()
                                                                        throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getClusterNodeLabels in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

updateApplicationPriority

public org.apache.hadoop.yarn.api.records.Priority updateApplicationPriority(org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
 org.apache.hadoop.yarn.api.records.Priority priority)
                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

updateApplicationPriority in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

signalToContainer

public void signalToContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId,
 org.apache.hadoop.yarn.api.records.SignalContainerCommand command)
                       throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

signalToContainer in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

killApplication

public void killApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 String diagnostics)
                     throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

killApplication in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getResourceProfiles

public Map<String,org.apache.hadoop.yarn.api.records.Resource> getResourceProfiles()
                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getResourceProfiles in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getResourceProfile

public org.apache.hadoop.yarn.api.records.Resource getResourceProfile(String profile)
                                                               throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getResourceProfile in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getResourceTypeInfo

public List<org.apache.hadoop.yarn.api.records.ResourceTypeInfo> getResourceTypeInfo()
                                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getResourceTypeInfo in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getClusterAttributes

public Set<org.apache.hadoop.yarn.api.records.NodeAttributeInfo> getClusterAttributes()
                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getClusterAttributes in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getAttributesToNodes

public Map<org.apache.hadoop.yarn.api.records.NodeAttributeKey,List<org.apache.hadoop.yarn.api.records.NodeToAttributeValue>> getAttributesToNodes(Set<org.apache.hadoop.yarn.api.records.NodeAttributeKey> attributes)
                                                                                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getAttributesToNodes in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getNodeToAttributes

public Map<String,Set<org.apache.hadoop.yarn.api.records.NodeAttribute>> getNodeToAttributes(Set<String> hostNames)
                                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getNodeToAttributes in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

shellToContainer

public void shellToContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId,
 org.apache.hadoop.yarn.api.records.ShellContainerCommand command)
                      throws IOException

Specified by:

shellToContainer in class org.apache.hadoop.yarn.client.api.YarnClient

Throws:

IOException