Uses of Interface
org.apache.drill.exec.rpc.ResponseSender
Package
Description
Communication security.
-
Uses of ResponseSender in org.apache.drill.exec.rpc
Modifier and TypeMethodDescriptionprotected void
BasicServer.handle
(SC connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) void
FailingRequestHandler.handle
(S connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) void
RequestHandler.handle
(S connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) Handle request of given type (rpcType) with message (pBody) and optional data (dBody) on the connection, and return the appropriate response.protected abstract void
RpcBus.handle
(C connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) -
Uses of ResponseSender in org.apache.drill.exec.rpc.control
Modifier and TypeMethodDescriptionprotected void
ControlClient.handle
(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) -
Uses of ResponseSender in org.apache.drill.exec.rpc.data
Modifier and TypeMethodDescriptionprotected void
DataClient.handle
(DataClientConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) -
Uses of ResponseSender in org.apache.drill.exec.rpc.security
Modifier and TypeMethodDescriptionvoid
ServerAuthenticationHandler.handle
(S connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) -
Uses of ResponseSender in org.apache.drill.exec.rpc.user
Modifier and TypeMethodDescriptionprotected void
UserClient.handle
(UserClient.UserToBitConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) -
Uses of ResponseSender in org.apache.drill.exec.work.batch
Modifier and TypeMethodDescriptionvoid
ControlMessageHandler.handle
(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) -
Uses of ResponseSender in org.apache.drill.exec.work.metadata
Modifier and TypeMethodDescriptionstatic Runnable
MetadataProvider.catalogs
(UserSession session, DrillbitContext dContext, UserProtos.GetCatalogsReq req, ResponseSender responseSender) static Runnable
MetadataProvider.columns
(UserSession session, DrillbitContext dContext, UserProtos.GetColumnsReq req, ResponseSender responseSender) static Runnable
MetadataProvider.schemas
(UserSession session, DrillbitContext dContext, UserProtos.GetSchemasReq req, ResponseSender responseSender) static Runnable
MetadataProvider.tables
(UserSession session, DrillbitContext dContext, UserProtos.GetTablesReq req, ResponseSender responseSender) ModifierConstructorDescriptionServerMetaWorker
(UserSession session, DrillbitContext context, UserProtos.GetServerMetaReq req, ResponseSender responseSender) -
Uses of ResponseSender in org.apache.drill.exec.work.prepare
ModifierConstructorDescriptionPreparedStatementWorker
(UserClientConnection connection, UserWorker userWorker, ResponseSender responseSender, UserProtos.CreatePreparedStatementReq req) -
Uses of ResponseSender in org.apache.drill.exec.work.user
Modifier and TypeMethodDescriptionvoid
UserWorker.submitCatalogMetadataWork
(UserSession session, UserProtos.GetCatalogsReq req, ResponseSender sender) void
UserWorker.submitColumnsMetadataWork
(UserSession session, UserProtos.GetColumnsReq req, ResponseSender sender) void
UserWorker.submitPreparedStatementWork
(UserClientConnection connection, UserProtos.CreatePreparedStatementReq req, ResponseSender sender) void
UserWorker.submitSchemasMetadataWork
(UserSession session, UserProtos.GetSchemasReq req, ResponseSender sender) void
UserWorker.submitServerMetadataWork
(UserSession session, UserProtos.GetServerMetaReq req, ResponseSender sender) void
UserWorker.submitTablesMetadataWork
(UserSession session, UserProtos.GetTablesReq req, ResponseSender sender)