Package org.apache.hadoop.ozone.protocolPB

Class StorageContainerDatanodeProtocolClientSideTranslatorPB

java.lang.Object
org.apache.hadoop.ozone.protocolPB.StorageContainerDatanodeProtocolClientSideTranslatorPB
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.ipc.ProtocolTranslator, StorageContainerDatanodeProtocol
public class StorageContainerDatanodeProtocolClientSideTranslatorPB extends Object implements StorageContainerDatanodeProtocol, org.apache.hadoop.ipc.ProtocolTranslator, Closeable
This class is the client-side translator to translate the requests made on the StorageContainerDatanodeProtocol interface to the RPC server implementing StorageContainerDatanodeProtocolPB.

  • Field Summary

    Fields inherited from interface org.apache.hadoop.ozone.protocol.StorageContainerDatanodeProtocol

    versionID

  • Constructor Summary

    Constructors
    Constructor
    Description
    StorageContainerDatanodeProtocolClientSideTranslatorPB(StorageContainerDatanodeProtocolPB rpcProxy)
    Constructs a Client side interface that calls into SCM datanode protocol.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Closes this stream and releases any system resources associated with it.
    Object
    getUnderlyingProxyObject()
    Return the proxy object underlying this protocol translator.
    org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionResponseProto
    getVersion(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionRequestProto request)
    Returns SCM version.
    org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisteredResponseProto
    register(org.apache.hadoop.hdds.protocol.proto.HddsProtos.ExtendedDatanodeDetailsProto extendedDatanodeDetailsProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto nodeReport, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReportsProto containerReportsRequestProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto pipelineReportsProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.LayoutVersionProto layoutInfo)
    Register Datanode.
    org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatResponseProto
    sendHeartbeat(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatRequestProto heartbeat)
    Send by datanode to SCM.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • StorageContainerDatanodeProtocolClientSideTranslatorPB

      public StorageContainerDatanodeProtocolClientSideTranslatorPB(StorageContainerDatanodeProtocolPB rpcProxy)
      Constructs a Client side interface that calls into SCM datanode protocol.
      Parameters:
      rpcProxy - - Proxy for RPC.

  • Method Details

    • close

      public void close()
      Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

      As noted in AutoCloseable.close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • getUnderlyingProxyObject

      public Object getUnderlyingProxyObject()
      Return the proxy object underlying this protocol translator.
      Specified by:
      getUnderlyingProxyObject in interface org.apache.hadoop.ipc.ProtocolTranslator
      Returns:
      the proxy object underlying this protocol translator.

    • getVersion

      public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionResponseProto getVersion(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionRequestProto request) throws IOException
      Returns SCM version.
      Specified by:
      getVersion in interface StorageContainerDatanodeProtocol
      Returns:
      Version info.
      Throws:
      IOException

    • sendHeartbeat

      public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatResponseProto sendHeartbeat(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatRequestProto heartbeat) throws IOException
      Send by datanode to SCM.
      Specified by:
      sendHeartbeat in interface StorageContainerDatanodeProtocol
      Parameters:
      heartbeat - node heartbeat
      Returns:
      - SCMHeartbeatResponseProto
      Throws:
      IOException

    • register

      public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisteredResponseProto register(org.apache.hadoop.hdds.protocol.proto.HddsProtos.ExtendedDatanodeDetailsProto extendedDatanodeDetailsProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto nodeReport, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReportsProto containerReportsRequestProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto pipelineReportsProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.LayoutVersionProto layoutInfo) throws IOException
      Register Datanode.
      Specified by:
      register in interface StorageContainerDatanodeProtocol
      Parameters:
      extendedDatanodeDetailsProto - - extended Datanode Details
      nodeReport - - Node Report.
      containerReportsRequestProto - - Container Reports.
      layoutInfo - - Layout Version Information.
      Returns:
      SCM Command.
      Throws:
      IOException