Modifier and Type | Method and Description |
---|---|
protected abstract void |
RpcBus.handle(C connection,
int rpcType,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody,
ResponseSender sender) |
protected void |
BasicServer.handle(SC 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.
|
void |
FailingRequestHandler.handle(S connection,
int rpcType,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody,
ResponseSender sender) |
Modifier and Type | Method and Description |
---|---|
protected void |
ControlClient.handle(ControlConnection connection,
int rpcType,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody,
ResponseSender sender) |
Modifier and Type | Method and Description |
---|---|
protected void |
DataClient.handle(DataClientConnection connection,
int rpcType,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody,
ResponseSender sender) |
Constructor and Description |
---|
AckSender(ResponseSender sender) |
Modifier and Type | Method and Description |
---|---|
void |
ServerAuthenticationHandler.handle(S connection,
int rpcType,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody,
ResponseSender sender) |
Modifier and Type | Method and Description |
---|---|
protected void |
UserClient.handle(UserClient.UserToBitConnection connection,
int rpcType,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody,
ResponseSender sender) |
Modifier and Type | Method and Description |
---|---|
void |
ControlMessageHandler.handle(ControlConnection connection,
int rpcType,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody,
ResponseSender sender) |
Modifier and Type | Method and Description |
---|---|
static 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) |
Constructor and Description |
---|
ServerMetaWorker(UserSession session,
DrillbitContext context,
UserProtos.GetServerMetaReq req,
ResponseSender responseSender) |
Constructor and Description |
---|
PreparedStatementWorker(UserClientConnection connection,
UserWorker userWorker,
ResponseSender responseSender,
UserProtos.CreatePreparedStatementReq req) |
Modifier and Type | Method and Description |
---|---|
void |
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) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.