Uses of Interface
org.apache.drill.exec.rpc.RpcOutcomeListener
Package
Description
Communication security.
-
Uses of RpcOutcomeListener in org.apache.drill.exec.ops
Modifier and TypeClassDescriptionclass
Listener that keeps track of the status of batches sent, and updates the SendingAccountor when status is received for each batchclass
Listener that keeps track of the status of batches sent, and updates the SendingAccountor when status is received for each batchModifierConstructorDescriptionAccountingDataTunnel
(DataTunnel tunnel, SendingAccountor sendingAccountor, RpcOutcomeListener<BitData.AckWithCredit> statusHandler) AccountingUserConnection
(UserClientConnection connection, SendingAccountor sendingAccountor, RpcOutcomeListener<GeneralRPCProtos.Ack> statusHandler) -
Uses of RpcOutcomeListener in org.apache.drill.exec.rpc
Modifier and TypeMethodDescriptionFutureBitCommand.getOutcomeListener()
ListeningCommand.getOutcomeListener()
RpcCommand.getOutcomeListener()
Modifier and TypeMethodDescriptionboolean
AbstractRemoteConnection.blockOnNotWritable
(RpcOutcomeListener<?> listener) boolean
RemoteConnection.blockOnNotWritable
(RpcOutcomeListener<?> listener) AbstractRemoteConnection.createNewRpcListener
(RpcOutcomeListener<V> handler, Class<V> clazz) Create a new rpc listener that will be notified when the response is returned.RemoteConnection.createNewRpcListener
(RpcOutcomeListener<V> handler, Class<V> clazz) abstract void
FutureBitCommand.doRpcCall
(RpcOutcomeListener<T> outcomeListener, C connection) abstract void
ListeningCommand.doRpcCall
(RpcOutcomeListener<T> outcomeListener, C connection) <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidBasicClient.send
(RpcOutcomeListener<RECEIVE> listener, SEND protobufBody, boolean allowInEventLoop, io.netty.buffer.ByteBuf... dataBodies) <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidBasicClient.send
(RpcOutcomeListener<RECEIVE> listener, T rpcType, SEND protobufBody, Class<RECEIVE> clazz, io.netty.buffer.ByteBuf... dataBodies) <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidRpcBus.send
(RpcOutcomeListener<RECEIVE> listener, C connection, T rpcType, SEND protobufBody, Class<RECEIVE> clazz, boolean allowInEventLoop, io.netty.buffer.ByteBuf... dataBodies) <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidRpcBus.send
(RpcOutcomeListener<RECEIVE> listener, C connection, T rpcType, SEND protobufBody, Class<RECEIVE> clazz, io.netty.buffer.ByteBuf... dataBodies) 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 RpcOutcomeListener in org.apache.drill.exec.rpc.control
Modifier and TypeMethodDescriptionvoid
ControlTunnel.cancelFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle) void
ControlTunnel.CancelQuery.doRpcCall
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection) void
ControlTunnel.CustomMessageSender.doRpcCall
(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener, ControlConnection connection) void
ControlTunnel.ReceiverFinished.doRpcCall
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ControlConnection connection) void
ControlTunnel.RequestProfile.doRpcCall
(RpcOutcomeListener<UserBitShared.QueryProfile> 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.SyncCustomMessageSender.doRpcCall
(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener, ControlConnection connection) void
ControlTunnel.informReceiverFinished
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, BitControl.FinishedReceiver finishedReceiver) <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidControlConnection.send
(RpcOutcomeListener<RECEIVE> outcomeListener, BitControl.RpcType rpcType, SEND protobufBody, Class<RECEIVE> clazz, io.netty.buffer.ByteBuf... dataBodies) void
ControlTunnel.CustomTunnel.send
(RpcOutcomeListener<RECEIVE> listener, SEND messageToSend, io.netty.buffer.ByteBuf... dataBodies) Send a message using a custom listener.void
ControlTunnel.sendFragments
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, BitControl.InitializeFragments fragments) <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidControlConnection.sendUnsafe
(RpcOutcomeListener<RECEIVE> outcomeListener, BitControl.RpcType rpcType, SEND protobufBody, Class<RECEIVE> clazz, io.netty.buffer.ByteBuf... dataBodies) void
ControlTunnel.unpauseFragment
(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle) ModifierConstructorDescriptionCustomMessageSender
(RpcOutcomeListener<BitControl.CustomMessage> listener, BitControl.CustomMessage message, io.netty.buffer.ByteBuf[] dataBodies) 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 RpcOutcomeListener in org.apache.drill.exec.rpc.data
Modifier and TypeMethodDescription<SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidDataClientConnection.send
(RpcOutcomeListener<RECEIVE> outcomeListener, BitData.RpcType rpcType, SEND protobufBody, Class<RECEIVE> clazz, io.netty.buffer.ByteBuf... dataBodies) void
DataTunnel.sendRecordBatch
(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, FragmentWritableBatch batch) void
DataTunnel.sendRuntimeFilter
(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, RuntimeFilterWritable runtimeFilter) -
Uses of RpcOutcomeListener in org.apache.drill.exec.rpc.security
Modifier and TypeClassDescriptionclass
AuthenticationOutcomeListener<T extends com.google.protobuf.Internal.EnumLite,
C extends ClientConnection, HS extends com.google.protobuf.MessageLite, HR extends com.google.protobuf.MessageLite> Handles SASL exchange, on the client-side.ModifierConstructorDescriptionAuthenticationOutcomeListener
(BasicClient<T, C, HS, HR> client, C connection, T saslRpcType, org.apache.hadoop.security.UserGroupInformation ugi, RpcOutcomeListener<?> completionListener) -
Uses of RpcOutcomeListener in org.apache.drill.exec.rpc.user
Modifier and TypeMethodDescriptionQueryResultHandler.getWrappedListener
(UserResultsListener resultsListener) Modifier and TypeMethodDescriptionprotected <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
voidUserClient.send
(RpcOutcomeListener<RECEIVE> listener, UserProtos.RpcType rpcType, SEND protobufBody, Class<RECEIVE> clazz, boolean allowInEventLoop, io.netty.buffer.ByteBuf... dataBodies) void
UserServer.BitToUserConnection.sendData
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data) void
UserServer.BitToUserConnection.sendResult
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, UserBitShared.QueryResult result) -
Uses of RpcOutcomeListener in org.apache.drill.exec.server.rest
Modifier and TypeMethodDescriptionvoid
WebUserConnection.sendData
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data) -
Uses of RpcOutcomeListener 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 RpcOutcomeListener in org.apache.drill.exec.work