Uses of Class
org.apache.drill.exec.proto.GeneralRPCProtos.Ack
Package
Description
Java client API for submitting queries and accepting result sets from a Drill
server.
-
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.client
Modifier and TypeMethodDescriptionDrillClient.cancelQuery
(UserBitShared.QueryId id) DrillClient.resumeQuery
(UserBitShared.QueryId queryId) -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.ops
Modifier and TypeMethodDescriptionvoid
StatusHandler.success
(GeneralRPCProtos.Ack value, io.netty.buffer.ByteBuf buffer) ModifierConstructorDescriptionAccountingUserConnection
(UserClientConnection connection, SendingAccountor sendingAccountor, RpcOutcomeListener<GeneralRPCProtos.Ack> statusHandler) -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.proto
Modifier and TypeFieldDescriptionstatic final com.google.protobuf.Parser<GeneralRPCProtos.Ack>
GeneralRPCProtos.Ack.PARSER
Deprecated.Modifier and TypeMethodDescriptionGeneralRPCProtos.Ack.Builder.build()
GeneralRPCProtos.Ack.Builder.buildPartial()
static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.getDefaultInstance()
GeneralRPCProtos.Ack.Builder.getDefaultInstanceForType()
GeneralRPCProtos.Ack.getDefaultInstanceForType()
SchemaGeneralRPCProtos.Ack.MessageSchema.newMessage()
static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseDelimitedFrom
(InputStream input) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseDelimitedFrom
(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(byte[] data) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(com.google.protobuf.ByteString data) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(com.google.protobuf.CodedInputStream input) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(InputStream input) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(ByteBuffer data) static GeneralRPCProtos.Ack
GeneralRPCProtos.Ack.parseFrom
(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) Modifier and TypeMethodDescriptioncom.google.protobuf.Parser<GeneralRPCProtos.Ack>
GeneralRPCProtos.Ack.getParserForType()
static com.google.protobuf.Parser<GeneralRPCProtos.Ack>
GeneralRPCProtos.Ack.parser()
SchemaGeneralRPCProtos.Ack.MessageSchema.typeClass()
Modifier and TypeMethodDescriptionboolean
SchemaGeneralRPCProtos.Ack.MessageSchema.isInitialized
(GeneralRPCProtos.Ack message) GeneralRPCProtos.Ack.Builder.mergeFrom
(GeneralRPCProtos.Ack other) void
SchemaGeneralRPCProtos.Ack.MessageSchema.mergeFrom
(io.protostuff.Input input, GeneralRPCProtos.Ack message) static GeneralRPCProtos.Ack.Builder
GeneralRPCProtos.Ack.newBuilder
(GeneralRPCProtos.Ack prototype) void
SchemaGeneralRPCProtos.Ack.MessageSchema.writeTo
(io.protostuff.Output output, GeneralRPCProtos.Ack message) -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.rpc
Modifier and TypeFieldDescriptionstatic final GeneralRPCProtos.Ack
Acks.FAIL
static final GeneralRPCProtos.Ack
Acks.OK
Modifier and TypeMethodDescriptionvoid
UserClientConnection.sendData
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data) Send query data to client.void
AbstractDisposableUserClientConnection.sendResult
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, UserBitShared.QueryResult result) void
UserClientConnection.sendResult
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, UserBitShared.QueryResult result) Send query result outcome to client. -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.rpc.control
Modifier and TypeMethodDescriptionControlTunnel.requestCancelQuery
(UserBitShared.QueryId queryId) ControlTunnel.sendFragmentStatus
(BitControl.FragmentStatus status) Modifier and TypeMethodDescriptionvoid
ControlTunnel.cancelFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle) void
ControlTunnel.CancelQuery.doRpcCall
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection) void
ControlTunnel.ReceiverFinished.doRpcCall
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection) void
ControlTunnel.SendFragment.doRpcCall
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection) void
ControlTunnel.SendFragmentStatus.doRpcCall
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection) void
ControlTunnel.SignalFragment.doRpcCall
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection) void
ControlTunnel.informReceiverFinished
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, BitControl.FinishedReceiver finishedReceiver) void
ControlTunnel.sendFragments
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, BitControl.InitializeFragments fragments) void
ControlTunnel.unpauseFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle) ModifierConstructorDescriptionReceiverFinished
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, BitControl.FinishedReceiver finishedReceiver) SendFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, BitControl.InitializeFragments fragments) SignalFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, ExecProtos.FragmentHandle handle, BitControl.RpcType type) -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.rpc.user
Modifier and TypeMethodDescriptionvoid
UserServer.BitToUserConnection.sendData
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data) void
UserServer.BitToUserConnection.sendResult
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, UserBitShared.QueryResult result) -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.server.rest
Modifier and TypeMethodDescriptionvoid
WebUserConnection.sendData
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data) -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.server.rest.stream
Modifier and TypeMethodDescriptionvoid
StreamingHttpConnection.sendData
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data) Called from query thread, specifically from the Screen operator, for each batch. -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.work.batch
Modifier and TypeMethodDescriptionControlMessageHandler.cancelFragment
(ExecProtos.FragmentHandle handle) ControlMessageHandler.initializeFragment
(BitControl.InitializeFragments fragments) ControlMessageHandler.receivingFragmentFinished
(BitControl.FinishedReceiver finishedReceiver) ControlMessageHandler.requestFragmentStatus
(BitControl.FragmentStatus status) ControlMessageHandler.requestQueryCancel
(UserBitShared.QueryId queryId) ControlMessageHandler.resumeFragment
(ExecProtos.FragmentHandle handle) -
Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.work.user
Modifier and TypeMethodDescriptionUserWorker.cancelQuery
(UserBitShared.QueryId query) UserWorker.resumeQuery
(UserBitShared.QueryId queryId)