Package org.apache.hadoop.hdfs.protocol.datatransfer

Class Receiver

java.lang.Object
org.apache.hadoop.hdfs.protocol.datatransfer.Receiver
All Implemented Interfaces:
org.apache.hadoop.hdfs.protocol.datatransfer.DataTransferProtocol
@Private @Evolving public abstract class Receiver extends Object implements org.apache.hadoop.hdfs.protocol.datatransfer.DataTransferProtocol
Receiver

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected DataInputStream
    in
     

    Fields inherited from interface org.apache.hadoop.hdfs.protocol.datatransfer.DataTransferProtocol

    DATA_TRANSFER_VERSION, LOG

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    Receiver(org.apache.hadoop.tracing.Tracer tracer)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    initialize(DataInputStream in)
    Initialize a receiver for DataTransferProtocol with a socket.
    protected final void
    processOp(org.apache.hadoop.hdfs.protocol.datatransfer.Op op)
    Process op by the corresponding method.
    protected final org.apache.hadoop.hdfs.protocol.datatransfer.Op
    readOp()
    Read an Op.

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.hdfs.protocol.datatransfer.DataTransferProtocol

    blockChecksum, blockGroupChecksum, copyBlock, readBlock, releaseShortCircuitFds, replaceBlock, requestShortCircuitFds, requestShortCircuitShm, transferBlock, writeBlock

  • Field Details

  • Constructor Details

    • Receiver

      protected Receiver(org.apache.hadoop.tracing.Tracer tracer)

  • Method Details

    • initialize

      protected void initialize(DataInputStream in)
      Initialize a receiver for DataTransferProtocol with a socket.

    • readOp

      protected final org.apache.hadoop.hdfs.protocol.datatransfer.Op readOp() throws IOException
      Read an Op. It also checks protocol version.
      Throws:
      IOException

    • processOp

      protected final void processOp(org.apache.hadoop.hdfs.protocol.datatransfer.Op op) throws IOException
      Process op by the corresponding method.
      Throws:
      IOException