Uses of Interface
org.apache.drill.exec.rpc.RpcOutcomeListener
Packages that use RpcOutcomeListener
Package
Description
Communication security.
-
Uses of RpcOutcomeListener in org.apache.drill.exec.ops
Classes in org.apache.drill.exec.ops that implement RpcOutcomeListenerModifier 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 batchConstructors in org.apache.drill.exec.ops with parameters of type RpcOutcomeListenerModifierConstructorDescriptionAccountingDataTunnel
(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
Classes in org.apache.drill.exec.rpc that implement RpcOutcomeListenerMethods in org.apache.drill.exec.rpc that return RpcOutcomeListenerModifier and TypeMethodDescriptionFutureBitCommand.getOutcomeListener()
ListeningCommand.getOutcomeListener()
RpcCommand.getOutcomeListener()
Methods in org.apache.drill.exec.rpc with parameters of type RpcOutcomeListenerModifier 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.Constructors in org.apache.drill.exec.rpc with parameters of type RpcOutcomeListener -
Uses of RpcOutcomeListener in org.apache.drill.exec.rpc.control
Methods in org.apache.drill.exec.rpc.control with parameters of type RpcOutcomeListenerModifier 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) Constructors in org.apache.drill.exec.rpc.control with parameters of type RpcOutcomeListenerModifierConstructorDescriptionCustomMessageSender
(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
Methods in org.apache.drill.exec.rpc.data with parameters of type RpcOutcomeListenerModifier 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
Classes in org.apache.drill.exec.rpc.security that implement RpcOutcomeListenerModifier 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.Constructors in org.apache.drill.exec.rpc.security with parameters of type RpcOutcomeListenerModifierConstructorDescriptionAuthenticationOutcomeListener
(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
Methods in org.apache.drill.exec.rpc.user that return RpcOutcomeListenerModifier and TypeMethodDescriptionQueryResultHandler.getWrappedListener
(UserResultsListener resultsListener) Methods in org.apache.drill.exec.rpc.user with parameters of type RpcOutcomeListenerModifier 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
Methods in org.apache.drill.exec.server.rest with parameters of type RpcOutcomeListenerModifier and TypeMethodDescriptionvoid
WebUserConnection.sendData
(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, QueryDataPackage data) -
Uses of RpcOutcomeListener in org.apache.drill.exec.server.rest.stream
Methods in org.apache.drill.exec.server.rest.stream with parameters of type RpcOutcomeListenerModifier 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
Classes in org.apache.drill.exec.work that implement RpcOutcomeListener