@InterfaceAudience.Private @InterfaceStability.Evolving public abstract class Receiver extends Object implements DataTransferProtocol
Modifier and Type | Field and Description |
---|---|
protected DataInputStream |
in |
DATA_TRANSFER_VERSION, LOG
Constructor and Description |
---|
Receiver() |
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
blockChecksum, copyBlock, readBlock, replaceBlock, requestShortCircuitFds, transferBlock, writeBlock
protected DataInputStream in
protected void initialize(DataInputStream in)
protected final Op readOp() throws IOException
IOException
protected final void processOp(Op op) throws IOException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.