Uses of Class
org.apache.drill.exec.proto.GeneralRPCProtos.Ack

Packages that use GeneralRPCProtos.Ack

Package	Description
org.apache.drill.exec.client	Java client API for submitting queries and accepting result sets from a Drill server.
org.apache.drill.exec.ops
org.apache.drill.exec.proto
org.apache.drill.exec.rpc
org.apache.drill.exec.rpc.control
org.apache.drill.exec.rpc.user
org.apache.drill.exec.server.rest
org.apache.drill.exec.server.rest.stream
org.apache.drill.exec.work.batch
org.apache.drill.exec.work.user

Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.client

Methods in org.apache.drill.exec.client that return types with arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
DrillRpcFuture<GeneralRPCProtos.Ack>	DrillClient.cancelQuery(UserBitShared.QueryId id)
DrillRpcFuture<GeneralRPCProtos.Ack>	DrillClient.resumeQuery(UserBitShared.QueryId queryId)

Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.ops

Methods in org.apache.drill.exec.ops with parameters of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
void	StatusHandler.success(GeneralRPCProtos.Ack value, io.netty.buffer.ByteBuf buffer)

Constructor parameters in org.apache.drill.exec.ops with type arguments of type GeneralRPCProtos.Ack

Constructor and Description
AccountingUserConnection(UserClientConnection connection, SendingAccountor sendingAccountor, RpcOutcomeListener<GeneralRPCProtos.Ack> statusHandler)

Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.proto

Fields in org.apache.drill.exec.proto with type parameters of type GeneralRPCProtos.Ack

Modifier and Type	Field and Description
static com.google.protobuf.Parser<GeneralRPCProtos.Ack>	GeneralRPCProtos.Ack.PARSER Deprecated.

Methods in org.apache.drill.exec.proto that return GeneralRPCProtos.Ack

Modifier and Type	Method and Description
GeneralRPCProtos.Ack	GeneralRPCProtos.Ack.Builder.build()
GeneralRPCProtos.Ack	GeneralRPCProtos.Ack.Builder.buildPartial()
static GeneralRPCProtos.Ack	GeneralRPCProtos.Ack.getDefaultInstance()
GeneralRPCProtos.Ack	GeneralRPCProtos.Ack.getDefaultInstanceForType()
GeneralRPCProtos.Ack	GeneralRPCProtos.Ack.Builder.getDefaultInstanceForType()
GeneralRPCProtos.Ack	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(ByteBuffer data)
static GeneralRPCProtos.Ack	GeneralRPCProtos.Ack.parseFrom(ByteBuffer 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)

Methods in org.apache.drill.exec.proto that return types with arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
com.google.protobuf.Parser<GeneralRPCProtos.Ack>	GeneralRPCProtos.Ack.getParserForType()
static com.google.protobuf.Parser<GeneralRPCProtos.Ack>	GeneralRPCProtos.Ack.parser()
Class<GeneralRPCProtos.Ack>	SchemaGeneralRPCProtos.Ack.MessageSchema.typeClass()

Methods in org.apache.drill.exec.proto with parameters of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
boolean	SchemaGeneralRPCProtos.Ack.MessageSchema.isInitialized(GeneralRPCProtos.Ack message)
GeneralRPCProtos.Ack.Builder	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

Fields in org.apache.drill.exec.rpc declared as GeneralRPCProtos.Ack

Modifier and Type	Field and Description
static GeneralRPCProtos.Ack	Acks.FAIL
static GeneralRPCProtos.Ack	Acks.OK

Method parameters in org.apache.drill.exec.rpc with type arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
void	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

Methods in org.apache.drill.exec.rpc.control that return types with arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
DrillRpcFuture<GeneralRPCProtos.Ack>	ControlTunnel.requestCancelQuery(UserBitShared.QueryId queryId)
DrillRpcFuture<GeneralRPCProtos.Ack>	ControlTunnel.sendFragmentStatus(BitControl.FragmentStatus status)

Method parameters in org.apache.drill.exec.rpc.control with type arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
void	ControlTunnel.cancelFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle)
void	ControlTunnel.SendFragmentStatus.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.ReceiverFinished.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.SignalFragment.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.SendFragment.doRpcCall(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection)
void	ControlTunnel.CancelQuery.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)

Constructor parameters in org.apache.drill.exec.rpc.control with type arguments of type GeneralRPCProtos.Ack

Constructor and Description
ReceiverFinished(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

Method parameters in org.apache.drill.exec.rpc.user with type arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
void	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

Method parameters in org.apache.drill.exec.server.rest with type arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
void	WebUserConnection.sendData(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data)

Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.server.rest.stream

Method parameters in org.apache.drill.exec.server.rest.stream with type arguments of type GeneralRPCProtos.Ack

Modifier and Type	Method and Description
void	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

Methods in org.apache.drill.exec.work.batch that return GeneralRPCProtos.Ack

Modifier and Type	Method and Description
GeneralRPCProtos.Ack	ControlMessageHandler.cancelFragment(ExecProtos.FragmentHandle handle)
GeneralRPCProtos.Ack	ControlMessageHandler.initializeFragment(BitControl.InitializeFragments fragments)
GeneralRPCProtos.Ack	ControlMessageHandler.receivingFragmentFinished(BitControl.FinishedReceiver finishedReceiver)
GeneralRPCProtos.Ack	ControlMessageHandler.requestFragmentStatus(BitControl.FragmentStatus status)
GeneralRPCProtos.Ack	ControlMessageHandler.requestQueryCancel(UserBitShared.QueryId queryId)
GeneralRPCProtos.Ack	ControlMessageHandler.resumeFragment(ExecProtos.FragmentHandle handle)

Uses of GeneralRPCProtos.Ack in org.apache.drill.exec.work.user

Methods in org.apache.drill.exec.work.user that return GeneralRPCProtos.Ack

Modifier and Type	Method and Description
GeneralRPCProtos.Ack	UserWorker.cancelQuery(UserBitShared.QueryId query)
GeneralRPCProtos.Ack	UserWorker.resumeQuery(UserBitShared.QueryId queryId)