org.apache.hadoop.hdfs.protocol.datatransfer

Class Receiver

java.lang.Object

org.apache.hadoop.hdfs.protocol.datatransfer.Receiver

All Implemented Interfaces:

DataTransferProtocol

@InterfaceAudience.Private
@InterfaceStability.Evolving
public abstract class Receiver
extends Object
implements DataTransferProtocol

Receiver

Field Summary

Fields

Modifier and Type	Field and Description
protected DataInputStream	in

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

DATA_TRANSFER_VERSION, LOG

Constructor Summary

Constructors

Constructor and Description
Receiver()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	initialize(DataInputStream in) Initialize a receiver for DataTransferProtocol with a socket.
protected void	processOp(Op op) Process op by the corresponding method.
protected 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, copyBlock, readBlock, replaceBlock, requestShortCircuitFds, transferBlock, writeBlock

Field Detail

in

protected DataInputStream in

Constructor Detail

Receiver

public Receiver()

Method Detail

initialize

protected void initialize(DataInputStream in)

Initialize a receiver for DataTransferProtocol with a socket.

readOp

protected final Op readOp()
                   throws IOException

Read an Op. It also checks protocol version.

Throws:

IOException

processOp

protected final void processOp(Op op)
                        throws IOException

Process op by the corresponding method.

Throws:

IOException