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 and 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 and 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 and 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 Detail

pBody

public io.netty.buffer.ByteBuf pBody

dBody

public io.netty.buffer.ByteBuf dBody

Constructor Detail

InboundRpcMessage

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

Method Detail

getBodySize

public int getBodySize()

Specified by:

getBodySize in class RpcMessage

toString

public String toString()

Overrides:

toString in class Object

getProtobufBodyAsIS

public InputStream getProtobufBodyAsIS()