Class OutboundRpcMessage

java.lang.Object
org.apache.drill.exec.rpc.RpcMessage
org.apache.drill.exec.rpc.OutboundRpcMessage

public class OutboundRpcMessage extends RpcMessage
  • 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