@InterfaceAudience.Private public class ApplicationClientProtocolPBClientImpl extends Object implements org.apache.hadoop.yarn.api.ApplicationClientProtocol, Closeable
Constructor and Description |
---|
ApplicationClientProtocolPBClientImpl(long clientVersion,
InetSocketAddress addr,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse |
cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request) |
void |
close() |
org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteResponse |
deleteReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse |
forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportResponse |
getApplicationAttemptReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsResponse |
getApplicationAttempts(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse |
getApplicationReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse |
getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse |
getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse |
getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse |
getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse |
getContainerReport(org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetContainersResponse |
getContainers(org.apache.hadoop.yarn.api.protocolrecords.GetContainersRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse |
getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse |
getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse |
getNodeToLabels(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse |
getQueueInfo(org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse |
getQueueUserAcls(org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse |
moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenResponse |
renewDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse |
submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse |
submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse |
updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request) |
public ApplicationClientProtocolPBClientImpl(long clientVersion, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
forceKillApplication
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse getApplicationReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getApplicationReport
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getClusterMetrics
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getNewApplication
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
submitApplication
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getApplications
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getClusterNodes
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse getQueueInfo(org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getQueueInfo
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse getQueueUserAcls(org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getQueueUserAcls
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getDelegationToken
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenResponse renewDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
renewDelegationToken
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
cancelDelegationToken
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
moveApplicationAcrossQueues
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportResponse getApplicationAttemptReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getApplicationAttemptReport
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsResponse getApplicationAttempts(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getApplicationAttempts
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse getContainerReport(org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getContainerReport
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetContainersResponse getContainers(org.apache.hadoop.yarn.api.protocolrecords.GetContainersRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getContainers
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
submitReservation
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
updateReservation
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
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
deleteReservation
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse getNodeToLabels(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getNodeToLabels
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getClusterNodeLabels
in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
Copyright © 2018 Apache Software Foundation. All Rights Reserved.