Uses of Class
org.apache.drill.exec.proto.BitControl.CustomMessage
-
Uses of BitControl.CustomMessage in org.apache.drill.exec.proto
Modifier and TypeFieldDescriptionstatic final com.google.protobuf.Parser<BitControl.CustomMessage>
BitControl.CustomMessage.PARSER
Deprecated.Modifier and TypeMethodDescriptionBitControl.CustomMessage.Builder.build()
BitControl.CustomMessage.Builder.buildPartial()
static BitControl.CustomMessage
BitControl.CustomMessage.getDefaultInstance()
BitControl.CustomMessage.Builder.getDefaultInstanceForType()
BitControl.CustomMessage.getDefaultInstanceForType()
SchemaBitControl.CustomMessage.MessageSchema.newMessage()
static BitControl.CustomMessage
BitControl.CustomMessage.parseDelimitedFrom
(InputStream input) static BitControl.CustomMessage
BitControl.CustomMessage.parseDelimitedFrom
(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(byte[] data) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(com.google.protobuf.ByteString data) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(com.google.protobuf.CodedInputStream input) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(InputStream input) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(ByteBuffer data) static BitControl.CustomMessage
BitControl.CustomMessage.parseFrom
(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) Modifier and TypeMethodDescriptioncom.google.protobuf.Parser<BitControl.CustomMessage>
BitControl.CustomMessage.getParserForType()
static com.google.protobuf.Parser<BitControl.CustomMessage>
BitControl.CustomMessage.parser()
SchemaBitControl.CustomMessage.MessageSchema.typeClass()
Modifier and TypeMethodDescriptionboolean
SchemaBitControl.CustomMessage.MessageSchema.isInitialized
(BitControl.CustomMessage message) BitControl.CustomMessage.Builder.mergeFrom
(BitControl.CustomMessage other) void
SchemaBitControl.CustomMessage.MessageSchema.mergeFrom
(io.protostuff.Input input, BitControl.CustomMessage message) BitControl.CustomMessage.newBuilder
(BitControl.CustomMessage prototype) void
SchemaBitControl.CustomMessage.MessageSchema.writeTo
(io.protostuff.Output output, BitControl.CustomMessage message) -
Uses of BitControl.CustomMessage in org.apache.drill.exec.rpc.control
Modifier and TypeMethodDescriptionControlTunnel.CustomMessageSender.getMessage()
ControlTunnel.SyncCustomMessageSender.getMessage()
Modifier and TypeMethodDescriptionCustomHandlerRegistry.handle
(BitControl.CustomMessage message, DrillBuf dBody) Modifier and TypeMethodDescriptionvoid
ControlTunnel.CustomMessageSender.doRpcCall
(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener, ControlConnection connection) void
ControlTunnel.SyncCustomMessageSender.doRpcCall
(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener, ControlConnection connection) ModifierConstructorDescriptionCustomMessageSender
(RpcOutcomeListener<BitControl.CustomMessage> listener, BitControl.CustomMessage message, io.netty.buffer.ByteBuf[] dataBodies) SyncCustomMessageSender
(BitControl.CustomMessage message, io.netty.buffer.ByteBuf[] dataBodies) ModifierConstructorDescriptionCustomFuture
(Controller.CustomSerDe<RECEIVE> serde, DrillRpcFuture<BitControl.CustomMessage> future) CustomMessageSender
(RpcOutcomeListener<BitControl.CustomMessage> listener, BitControl.CustomMessage message, io.netty.buffer.ByteBuf[] dataBodies)