Package org.apache.drill.exec.rpc

Class InboundRpcMessage

java.lang.Object

org.apache.drill.exec.rpc.RpcMessage

org.apache.drill.exec.rpc.InboundRpcMessage

public class InboundRpcMessage
extends RpcMessage

Field Summary

Fields

Modifier and Type	Field	Description
io.netty.buffer.ByteBuf	dBody
io.netty.buffer.ByteBuf	pBody

Fields inherited from class org.apache.drill.exec.rpc.RpcMessage

coordinationId, mode, rpcType

Constructor Summary

Constructors

Constructor	Description
InboundRpcMessage(GeneralRPCProtos.RpcMode mode, int rpcType, int coordinationId, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody)

Method Summary

Modifier and Type	Method	Description
int	getBodySize()
InputStream	getProtobufBodyAsIS()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

pBody

public io.netty.buffer.ByteBuf pBody

dBody

public io.netty.buffer.ByteBuf dBody

Constructor Details

InboundRpcMessage

public InboundRpcMessage(GeneralRPCProtos.RpcMode mode,
 int rpcType,
 int coordinationId,
 io.netty.buffer.ByteBuf pBody,
 io.netty.buffer.ByteBuf dBody)

Method Details

getBodySize

public int getBodySize()

Specified by:

getBodySize in class RpcMessage

toString

public String toString()

Overrides:

toString in class Object

getProtobufBodyAsIS

public InputStream getProtobufBodyAsIS()