@InterfaceAudience.Private public class ContainerManagementProtocolPBClientImpl extends Object implements org.apache.hadoop.yarn.api.ContainerManagementProtocol, Closeable
Constructor and Description |
---|
ContainerManagementProtocolPBClientImpl(long clientVersion,
InetSocketAddress addr,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.yarn.api.protocolrecords.CommitResponse |
commitLastReInitialization(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesResponse |
getContainerStatuses(org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.IncreaseContainersResourceResponse |
increaseContainersResource(org.apache.hadoop.yarn.api.protocolrecords.IncreaseContainersResourceRequest request)
Deprecated.
|
org.apache.hadoop.yarn.api.protocolrecords.ResourceLocalizationResponse |
localize(org.apache.hadoop.yarn.api.protocolrecords.ResourceLocalizationRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.ReInitializeContainerResponse |
reInitializeContainer(org.apache.hadoop.yarn.api.protocolrecords.ReInitializeContainerRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.RestartContainerResponse |
restartContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
org.apache.hadoop.yarn.api.protocolrecords.RollbackResponse |
rollbackLastReInitialization(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
org.apache.hadoop.yarn.api.protocolrecords.SignalContainerResponse |
signalToContainer(org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse |
startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest requests) |
org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse |
stopContainers(org.apache.hadoop.yarn.api.protocolrecords.StopContainersRequest requests) |
org.apache.hadoop.yarn.api.protocolrecords.ContainerUpdateResponse |
updateContainer(org.apache.hadoop.yarn.api.protocolrecords.ContainerUpdateRequest request) |
public ContainerManagementProtocolPBClientImpl(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.StartContainersResponse startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest requests) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
startContainers
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse stopContainers(org.apache.hadoop.yarn.api.protocolrecords.StopContainersRequest requests) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
stopContainers
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesResponse getContainerStatuses(org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getContainerStatuses
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
@Deprecated public org.apache.hadoop.yarn.api.protocolrecords.IncreaseContainersResourceResponse increaseContainersResource(org.apache.hadoop.yarn.api.protocolrecords.IncreaseContainersResourceRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
increaseContainersResource
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.ContainerUpdateResponse updateContainer(org.apache.hadoop.yarn.api.protocolrecords.ContainerUpdateRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
updateContainer
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.SignalContainerResponse signalToContainer(org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
signalToContainer
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.ResourceLocalizationResponse localize(org.apache.hadoop.yarn.api.protocolrecords.ResourceLocalizationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
localize
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.ReInitializeContainerResponse reInitializeContainer(org.apache.hadoop.yarn.api.protocolrecords.ReInitializeContainerRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
reInitializeContainer
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.RestartContainerResponse restartContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
restartContainer
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.RollbackResponse rollbackLastReInitialization(org.apache.hadoop.yarn.api.records.ContainerId containerId) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
rollbackLastReInitialization
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.CommitResponse commitLastReInitialization(org.apache.hadoop.yarn.api.records.ContainerId containerId) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
commitLastReInitialization
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
Copyright © 2008–2018 Apache Software Foundation. All rights reserved.