| 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.rpc | |
| org.apache.drill.exec.rpc.control | |
| org.apache.drill.exec.rpc.user |
| Modifier and Type | Method and Description |
|---|---|
DrillRpcFuture<GeneralRPCProtos.Ack> |
DrillClient.cancelQuery(UserBitShared.QueryId id) |
DrillRpcFuture<UserProtos.CreatePreparedStatementResp> |
DrillClient.createPreparedStatement(String query)
Create a prepared statement for given the
query. |
DrillRpcFuture<UserProtos.GetCatalogsResp> |
DrillClient.getCatalogs(UserProtos.LikeFilter catalogNameFilter)
Get the list of catalogs in
INFORMATION_SCHEMA.CATALOGS table satisfying the given filters. |
DrillRpcFuture<UserProtos.GetColumnsResp> |
DrillClient.getColumns(UserProtos.LikeFilter catalogNameFilter,
UserProtos.LikeFilter schemaNameFilter,
UserProtos.LikeFilter tableNameFilter,
UserProtos.LikeFilter columnNameFilter)
Get the list of columns in
INFORMATION_SCHEMA.COLUMNS table satisfying the given filters. |
DrillRpcFuture<UserProtos.GetSchemasResp> |
DrillClient.getSchemas(UserProtos.LikeFilter catalogNameFilter,
UserProtos.LikeFilter schemaNameFilter)
Get the list of schemas in
INFORMATION_SCHEMA.SCHEMATA table satisfying the given filters. |
DrillRpcFuture<UserProtos.GetServerMetaResp> |
DrillClient.getServerMeta()
Get server meta information
Get meta information about the server like the the available functions
or the identifier quoting string used by the current session
|
DrillRpcFuture<UserProtos.GetTablesResp> |
DrillClient.getTables(UserProtos.LikeFilter catalogNameFilter,
UserProtos.LikeFilter schemaNameFilter,
UserProtos.LikeFilter tableNameFilter,
List<String> tableTypeFilter)
Get the list of tables in
INFORMATION_SCHEMA.TABLES table satisfying the given filters. |
DrillRpcFuture<UserProtos.QueryPlanFragments> |
DrillClient.planQuery(UserBitShared.QueryType type,
String query,
boolean isSplitPlan)
API to just plan a query without execution
|
DrillRpcFuture<GeneralRPCProtos.Ack> |
DrillClient.resumeQuery(UserBitShared.QueryId queryId) |
| Modifier and Type | Class and Description |
|---|---|
class |
RpcCheckedFuture<T> |
| Modifier and Type | Method and Description |
|---|---|
DrillRpcFuture<T> |
FutureBitCommand.getFuture() |
<SEND extends com.google.protobuf.MessageLite,RECEIVE extends com.google.protobuf.MessageLite> |
RpcBus.send(C connection,
T rpcType,
SEND protobufBody,
Class<RECEIVE> clazz,
io.netty.buffer.ByteBuf... dataBodies) |
<SEND extends com.google.protobuf.MessageLite,RECEIVE extends com.google.protobuf.MessageLite> |
BasicClient.send(T rpcType,
SEND protobufBody,
Class<RECEIVE> clazz,
io.netty.buffer.ByteBuf... dataBodies) |
| Modifier and Type | Method and Description |
|---|---|
DrillRpcFuture<GeneralRPCProtos.Ack> |
ControlTunnel.requestCancelQuery(UserBitShared.QueryId queryId) |
DrillRpcFuture<UserBitShared.QueryProfile> |
ControlTunnel.requestQueryProfile(UserBitShared.QueryId queryId) |
DrillRpcFuture<GeneralRPCProtos.Ack> |
ControlTunnel.sendFragmentStatus(BitControl.FragmentStatus status) |
| Constructor and Description |
|---|
CustomFuture(Controller.CustomSerDe<RECEIVE> serde,
DrillRpcFuture<BitControl.CustomMessage> future) |
| Modifier and Type | Method and Description |
|---|---|
DrillRpcFuture<UserProtos.QueryPlanFragments> |
UserClient.planQuery(UserProtos.GetQueryPlanFragments req)
planQuery is an API to plan a query without query execution
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.