Package org.apache.hadoop.hdfs.server.federation.router

Class RouterNamenodeProtocol

java.lang.Object
org.apache.hadoop.hdfs.server.federation.router.RouterNamenodeProtocol
All Implemented Interfaces:
org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
Direct Known Subclasses:
RouterAsyncNamenodeProtocol
public class RouterNamenodeProtocol extends Object implements org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
Module that implements all the RPC calls in NamenodeProtocol in the RouterRpcServer.

  • Field Summary

    Fields inherited from interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

    ACT_CHECKPOINT, ACT_SHUTDOWN, ACT_UNKNOWN, FATAL, NOTIFY, versionID

  • Constructor Summary

    Constructors
    Constructor
    Description
    RouterNamenodeProtocol(RouterRpcServer server)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    endCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration, org.apache.hadoop.hdfs.server.namenode.CheckpointSignature sig)
     
    void
    errorReport(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration, int errorCode, String msg)
     
    org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys
    getBlockKeys()
     
    org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations
    getBlocks(org.apache.hadoop.hdfs.protocol.DatanodeInfo datanode, long size, long minBlockSize, long hotBlockTimeInterval, org.apache.hadoop.fs.StorageType storageType)
     
    org.apache.hadoop.hdfs.server.protocol.RemoteEditLogManifest
    getEditLogManifest(long sinceTxId)
     
    long
    getMostRecentCheckpointTxId()
     
    long
    getMostRecentNameNodeFileTxId(org.apache.hadoop.hdfs.server.namenode.NNStorage.NameNodeFile nnf)
     
    Long
    getNextSPSPath()
     
    long
    getTransactionID()
     
    boolean
    isRollingUpgrade()
     
    boolean
    isUpgradeFinalized()
     
    org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration
    registerSubordinateNamenode(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration)
     
    org.apache.hadoop.hdfs.server.namenode.CheckpointSignature
    rollEditLog()
     
    org.apache.hadoop.hdfs.server.protocol.NamenodeCommand
    startCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration)
     
    org.apache.hadoop.hdfs.server.protocol.NamespaceInfo
    versionRequest()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • RouterNamenodeProtocol

      public RouterNamenodeProtocol(RouterRpcServer server)

  • Method Details

    • getBlocks

      public org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations getBlocks(org.apache.hadoop.hdfs.protocol.DatanodeInfo datanode, long size, long minBlockSize, long hotBlockTimeInterval, org.apache.hadoop.fs.StorageType storageType) throws IOException
      Specified by:
      getBlocks in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • getBlockKeys

      public org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys getBlockKeys() throws IOException
      Specified by:
      getBlockKeys in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • getTransactionID

      public long getTransactionID() throws IOException
      Specified by:
      getTransactionID in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • getMostRecentCheckpointTxId

      public long getMostRecentCheckpointTxId() throws IOException
      Specified by:
      getMostRecentCheckpointTxId in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • getMostRecentNameNodeFileTxId

      public long getMostRecentNameNodeFileTxId(org.apache.hadoop.hdfs.server.namenode.NNStorage.NameNodeFile nnf) throws IOException
      Specified by:
      getMostRecentNameNodeFileTxId in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • rollEditLog

      public org.apache.hadoop.hdfs.server.namenode.CheckpointSignature rollEditLog() throws IOException
      Specified by:
      rollEditLog in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • versionRequest

      public org.apache.hadoop.hdfs.server.protocol.NamespaceInfo versionRequest() throws IOException
      Specified by:
      versionRequest in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • errorReport

      public void errorReport(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration, int errorCode, String msg) throws IOException
      Specified by:
      errorReport in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • registerSubordinateNamenode

      public org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registerSubordinateNamenode(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration) throws IOException
      Specified by:
      registerSubordinateNamenode in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • startCheckpoint

      public org.apache.hadoop.hdfs.server.protocol.NamenodeCommand startCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration) throws IOException
      Specified by:
      startCheckpoint in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • endCheckpoint

      public void endCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration, org.apache.hadoop.hdfs.server.namenode.CheckpointSignature sig) throws IOException
      Specified by:
      endCheckpoint in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • getEditLogManifest

      public org.apache.hadoop.hdfs.server.protocol.RemoteEditLogManifest getEditLogManifest(long sinceTxId) throws IOException
      Specified by:
      getEditLogManifest in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • isUpgradeFinalized

      public boolean isUpgradeFinalized() throws IOException
      Specified by:
      isUpgradeFinalized in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • isRollingUpgrade

      public boolean isRollingUpgrade() throws IOException
      Specified by:
      isRollingUpgrade in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException

    • getNextSPSPath

      public Long getNextSPSPath() throws IOException
      Specified by:
      getNextSPSPath in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol
      Throws:
      IOException