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

Class ClientAMProtocolPBClientImpl

java.lang.Object
org.apache.hadoop.yarn.service.impl.pb.client.ClientAMProtocolPBClientImpl
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.yarn.service.ClientAMProtocol
public class ClientAMProtocolPBClientImpl extends Object implements org.apache.hadoop.yarn.service.ClientAMProtocol, Closeable

  • Constructor Summary

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

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.yarn.proto.ClientAMProtocol.CancelUpgradeResponseProto
    cancelUpgrade(org.apache.hadoop.yarn.proto.ClientAMProtocol.CancelUpgradeRequestProto request)
     
    void
    close()
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.DecommissionCompInstancesResponseProto
    decommissionCompInstances(org.apache.hadoop.yarn.proto.ClientAMProtocol.DecommissionCompInstancesRequestProto request)
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.FlexComponentsResponseProto
    flexComponents(org.apache.hadoop.yarn.proto.ClientAMProtocol.FlexComponentsRequestProto request)
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.GetCompInstancesResponseProto
    getCompInstances(org.apache.hadoop.yarn.proto.ClientAMProtocol.GetCompInstancesRequestProto request)
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.GetStatusResponseProto
    getStatus(org.apache.hadoop.yarn.proto.ClientAMProtocol.GetStatusRequestProto request)
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.RestartServiceResponseProto
    restart(org.apache.hadoop.yarn.proto.ClientAMProtocol.RestartServiceRequestProto request)
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.StopResponseProto
    stop(org.apache.hadoop.yarn.proto.ClientAMProtocol.StopRequestProto requestProto)
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.CompInstancesUpgradeResponseProto
    upgrade(org.apache.hadoop.yarn.proto.ClientAMProtocol.CompInstancesUpgradeRequestProto request)
     
    org.apache.hadoop.yarn.proto.ClientAMProtocol.UpgradeServiceResponseProto
    upgrade(org.apache.hadoop.yarn.proto.ClientAMProtocol.UpgradeServiceRequestProto request)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ClientAMProtocolPBClientImpl

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

  • Method Details

    • flexComponents

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.FlexComponentsResponseProto flexComponents(org.apache.hadoop.yarn.proto.ClientAMProtocol.FlexComponentsRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      flexComponents in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • getStatus

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.GetStatusResponseProto getStatus(org.apache.hadoop.yarn.proto.ClientAMProtocol.GetStatusRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getStatus in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • stop

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.StopResponseProto stop(org.apache.hadoop.yarn.proto.ClientAMProtocol.StopRequestProto requestProto) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      stop in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • upgrade

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.UpgradeServiceResponseProto upgrade(org.apache.hadoop.yarn.proto.ClientAMProtocol.UpgradeServiceRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      upgrade in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • restart

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.RestartServiceResponseProto restart(org.apache.hadoop.yarn.proto.ClientAMProtocol.RestartServiceRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      restart in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • upgrade

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.CompInstancesUpgradeResponseProto upgrade(org.apache.hadoop.yarn.proto.ClientAMProtocol.CompInstancesUpgradeRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      upgrade in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • getCompInstances

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.GetCompInstancesResponseProto getCompInstances(org.apache.hadoop.yarn.proto.ClientAMProtocol.GetCompInstancesRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      getCompInstances in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • cancelUpgrade

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.CancelUpgradeResponseProto cancelUpgrade(org.apache.hadoop.yarn.proto.ClientAMProtocol.CancelUpgradeRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      cancelUpgrade in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException

    • decommissionCompInstances

      public org.apache.hadoop.yarn.proto.ClientAMProtocol.DecommissionCompInstancesResponseProto decommissionCompInstances(org.apache.hadoop.yarn.proto.ClientAMProtocol.DecommissionCompInstancesRequestProto request) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
      Specified by:
      decommissionCompInstances in interface org.apache.hadoop.yarn.service.ClientAMProtocol
      Throws:
      IOException
      org.apache.hadoop.yarn.exceptions.YarnException