@InterfaceAudience.Private public class ContainerManagementProtocolPBServiceImpl extends Object implements ContainerManagementProtocolPB
Constructor and Description |
---|
ContainerManagementProtocolPBServiceImpl(org.apache.hadoop.yarn.api.ContainerManagementProtocol impl) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.proto.YarnServiceProtos.CommitResponseProto |
commitLastReInitialization(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto containerId) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusesResponseProto |
getContainerStatuses(org.apache.hadoop.thirdparty.protobuf.RpcController arg0,
org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusesRequestProto proto) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.GetLocalizationStatusesResponseProto |
getLocalizationStatuses(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnServiceProtos.GetLocalizationStatusesRequestProto request) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.IncreaseContainersResourceResponseProto |
increaseContainersResource(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnServiceProtos.IncreaseContainersResourceRequestProto proto) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.ResourceLocalizationResponseProto |
localize(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnServiceProtos.ResourceLocalizationRequestProto proto) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.ReInitializeContainerResponseProto |
reInitializeContainer(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnServiceProtos.ReInitializeContainerRequestProto proto) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.RestartContainerResponseProto |
restartContainer(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto containerId) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.RollbackResponseProto |
rollbackLastReInitialization(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto containerId) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.SignalContainerResponseProto |
signalToContainer(org.apache.hadoop.thirdparty.protobuf.RpcController arg0,
org.apache.hadoop.yarn.proto.YarnServiceProtos.SignalContainerRequestProto proto) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.StartContainersResponseProto |
startContainers(org.apache.hadoop.thirdparty.protobuf.RpcController arg0,
org.apache.hadoop.yarn.proto.YarnServiceProtos.StartContainersRequestProto proto) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.StopContainersResponseProto |
stopContainers(org.apache.hadoop.thirdparty.protobuf.RpcController arg0,
org.apache.hadoop.yarn.proto.YarnServiceProtos.StopContainersRequestProto proto) |
org.apache.hadoop.yarn.proto.YarnServiceProtos.ContainerUpdateResponseProto |
updateContainer(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
org.apache.hadoop.yarn.proto.YarnServiceProtos.ContainerUpdateRequestProto proto) |
public ContainerManagementProtocolPBServiceImpl(org.apache.hadoop.yarn.api.ContainerManagementProtocol impl)
public org.apache.hadoop.yarn.proto.YarnServiceProtos.StartContainersResponseProto startContainers(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.StartContainersRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
startContainers
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.StopContainersResponseProto stopContainers(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.StopContainersRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
stopContainers
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusesResponseProto getContainerStatuses(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusesRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
getContainerStatuses
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.IncreaseContainersResourceResponseProto increaseContainersResource(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServiceProtos.IncreaseContainersResourceRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
increaseContainersResource
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.ContainerUpdateResponseProto updateContainer(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServiceProtos.ContainerUpdateRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
updateContainer
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.SignalContainerResponseProto signalToContainer(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.SignalContainerRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
signalToContainer
in interface ContainerManagementProtocolPB
signalToContainer
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.ResourceLocalizationResponseProto localize(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServiceProtos.ResourceLocalizationRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
localize
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.ReInitializeContainerResponseProto reInitializeContainer(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServiceProtos.ReInitializeContainerRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
reInitializeContainer
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.RestartContainerResponseProto restartContainer(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto containerId) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
restartContainer
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.RollbackResponseProto rollbackLastReInitialization(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto containerId) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
rollbackLastReInitialization
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.CommitResponseProto commitLastReInitialization(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto containerId) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
commitLastReInitialization
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
public org.apache.hadoop.yarn.proto.YarnServiceProtos.GetLocalizationStatusesResponseProto getLocalizationStatuses(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServiceProtos.GetLocalizationStatusesRequestProto request) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
getLocalizationStatuses
in interface org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService.BlockingInterface
org.apache.hadoop.thirdparty.protobuf.ServiceException
Copyright © 2008–2022 Apache Software Foundation. All rights reserved.