Package org.apache.hadoop.yarn.server.api.impl.pb.service

Class DistributedSchedulingAMProtocolPBServiceImpl

java.lang.Object
org.apache.hadoop.yarn.server.api.impl.pb.service.DistributedSchedulingAMProtocolPBServiceImpl
All Implemented Interfaces:
org.apache.hadoop.yarn.api.ApplicationMasterProtocolPB, org.apache.hadoop.yarn.proto.ApplicationMasterProtocol.ApplicationMasterProtocolService.BlockingInterface, org.apache.hadoop.yarn.proto.DistributedSchedulingAMProtocol.DistributedSchedulingAMProtocolService.BlockingInterface, DistributedSchedulingAMProtocolPB
public class DistributedSchedulingAMProtocolPBServiceImpl extends Object implements DistributedSchedulingAMProtocolPB
Implementation of DistributedSchedulingAMProtocolPB.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DistributedSchedulingAMProtocolPBServiceImpl(DistributedSchedulingAMProtocol impl)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto
    allocate(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto proto)
     
    org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.DistributedSchedulingAllocateResponseProto
    allocateForDistributedScheduling(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.DistributedSchedulingAllocateRequestProto proto)
     
    org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterResponseProto
    finishApplicationMaster(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterRequestProto proto)
     
    org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterResponseProto
    registerApplicationMaster(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProto proto)
     
    org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.RegisterDistributedSchedulingAMResponseProto
    registerApplicationMasterForDistributedScheduling(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProto proto)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • registerApplicationMasterForDistributedScheduling

      public org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.RegisterDistributedSchedulingAMResponseProto registerApplicationMasterForDistributedScheduling(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
      Specified by:
      registerApplicationMasterForDistributedScheduling in interface org.apache.hadoop.yarn.proto.DistributedSchedulingAMProtocol.DistributedSchedulingAMProtocolService.BlockingInterface
      Throws:
      org.apache.hadoop.thirdparty.protobuf.ServiceException

    • allocateForDistributedScheduling

      public org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.DistributedSchedulingAllocateResponseProto allocateForDistributedScheduling(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.DistributedSchedulingAllocateRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
      Specified by:
      allocateForDistributedScheduling in interface org.apache.hadoop.yarn.proto.DistributedSchedulingAMProtocol.DistributedSchedulingAMProtocolService.BlockingInterface
      Throws:
      org.apache.hadoop.thirdparty.protobuf.ServiceException

    • allocate

      public org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto allocate(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
      Specified by:
      allocate in interface org.apache.hadoop.yarn.proto.ApplicationMasterProtocol.ApplicationMasterProtocolService.BlockingInterface
      Throws:
      org.apache.hadoop.thirdparty.protobuf.ServiceException

    • finishApplicationMaster

      public org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterResponseProto finishApplicationMaster(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
      Specified by:
      finishApplicationMaster in interface org.apache.hadoop.yarn.proto.ApplicationMasterProtocol.ApplicationMasterProtocolService.BlockingInterface
      Specified by:
      finishApplicationMaster in interface org.apache.hadoop.yarn.proto.DistributedSchedulingAMProtocol.DistributedSchedulingAMProtocolService.BlockingInterface
      Throws:
      org.apache.hadoop.thirdparty.protobuf.ServiceException

    • registerApplicationMaster

      public org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterResponseProto registerApplicationMaster(org.apache.hadoop.thirdparty.protobuf.RpcController arg0, org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProto proto) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
      Specified by:
      registerApplicationMaster in interface org.apache.hadoop.yarn.proto.ApplicationMasterProtocol.ApplicationMasterProtocolService.BlockingInterface
      Throws:
      org.apache.hadoop.thirdparty.protobuf.ServiceException