Package org.apache.drill.exec.rpc

Class OutboundRpcMessage

java.lang.Object

org.apache.drill.exec.rpc.RpcMessage

org.apache.drill.exec.rpc.OutboundRpcMessage

public class OutboundRpcMessage
extends RpcMessage

Field Summary

Fields

Modifier and Type	Field	Description
io.netty.buffer.ByteBuf[]	dBodies

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

coordinationId, mode, rpcType

Constructor Summary

Constructors

Constructor	Description
OutboundRpcMessage(GeneralRPCProtos.RpcMode mode, com.google.protobuf.Internal.EnumLite rpcType, int coordinationId, com.google.protobuf.MessageLite pBody, io.netty.buffer.ByteBuf... dBodies)

Method Summary

Modifier and Type	Method	Description
int	getBodySize()
int	getRawBodySize()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

dBodies

public io.netty.buffer.ByteBuf[] dBodies

Constructor Details

OutboundRpcMessage

public OutboundRpcMessage(GeneralRPCProtos.RpcMode mode,
 com.google.protobuf.Internal.EnumLite rpcType,
 int coordinationId,
 com.google.protobuf.MessageLite pBody,
 io.netty.buffer.ByteBuf... dBodies)

Method Details

getBodySize

public int getBodySize()

Specified by:

getBodySize in class RpcMessage

getRawBodySize

public int getRawBodySize()

toString

public String toString()

Overrides:

toString in class Object