Package org.apache.hadoop.hdfs.server.protocol

Interface InterDatanodeProtocol

All Known Implementing Classes:
DataNode, InterDatanodeProtocolTranslatorPB
@Private public interface InterDatanodeProtocol
An inter-datanode protocol for updating generation stamp

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final org.slf4j.Logger
    LOG
     
    static final long
    versionID
    Until version 9, this class InterDatanodeProtocol served as both the interface to the DN AND the RPC protocol used to communicate with the DN.

  • Method Summary

    Modifier and Type
    Method
    Description
    ReplicaRecoveryInfo
    initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock rBlock)
    Initialize a replica recovery.
    String
    updateReplicaUnderRecovery(org.apache.hadoop.hdfs.protocol.ExtendedBlock oldBlock, long recoveryId, long newBlockId, long newLength)
    Update replica with the new generation stamp and length.

  • Field Details

    • LOG

      static final org.slf4j.Logger LOG

    • versionID

      static final long versionID
      Until version 9, this class InterDatanodeProtocol served as both the interface to the DN AND the RPC protocol used to communicate with the DN. This class is used by both the DN to insulate from the protocol serialization. If you are adding/changing DN's interface then you need to change both this class and ALSO related protocol buffer wire protocol definition in InterDatanodeProtocol.proto. For more details on protocol buffer wire protocol, please see .../org/apache/hadoop/hdfs/protocolPB/overview.html
      See Also:

  • Method Details

    • initReplicaRecovery

      ReplicaRecoveryInfo initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock rBlock) throws IOException
      Initialize a replica recovery.
      Returns:
      actual state of the replica on this data-node or null if data-node does not have the replica.
      Throws:
      IOException

    • updateReplicaUnderRecovery

      String updateReplicaUnderRecovery(org.apache.hadoop.hdfs.protocol.ExtendedBlock oldBlock, long recoveryId, long newBlockId, long newLength) throws IOException
      Update replica with the new generation stamp and length.
      Throws:
      IOException