Package org.apache.hadoop.yarn.api.impl.pb.client

Class ContainerManagementProtocolPBClientImpl

java.lang.Object

org.apache.hadoop.yarn.api.impl.pb.client.ContainerManagementProtocolPBClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.yarn.api.ContainerManagementProtocol

@Private
public class ContainerManagementProtocolPBClientImpl
extends Object
implements org.apache.hadoop.yarn.api.ContainerManagementProtocol, Closeable

Constructor Summary

Constructors

Constructor	Description
ContainerManagementProtocolPBClientImpl(long clientVersion, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	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.GetLocalizationStatusesResponse	getLocalizationStatuses(org.apache.hadoop.yarn.api.protocolrecords.GetLocalizationStatusesRequest 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)

Methods inherited from class java.lang.Object

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

Constructor Details

ContainerManagementProtocolPBClientImpl

public ContainerManagementProtocolPBClientImpl(long clientVersion,
 InetSocketAddress addr,
 org.apache.hadoop.conf.Configuration conf)
                                        throws IOException

Throws:

IOException

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

startContainers

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

Specified by:

startContainers in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

stopContainers

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

Specified by:

stopContainers in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getContainerStatuses

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

Specified by:

getContainerStatuses in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

increaseContainersResource

@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

Deprecated.

Specified by:

increaseContainersResource in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

updateContainer

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

Specified by:

updateContainer in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

signalToContainer

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

Specified by:

signalToContainer in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

localize

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

Specified by:

localize in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

reInitializeContainer

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

Specified by:

reInitializeContainer in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

restartContainer

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

Specified by:

restartContainer in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

rollbackLastReInitialization

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

Specified by:

rollbackLastReInitialization in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

commitLastReInitialization

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

Specified by:

commitLastReInitialization in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getLocalizationStatuses

public org.apache.hadoop.yarn.api.protocolrecords.GetLocalizationStatusesResponse getLocalizationStatuses(org.apache.hadoop.yarn.api.protocolrecords.GetLocalizationStatusesRequest request)
                                                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getLocalizationStatuses in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException