| Package | Description |
|---|---|
| org.apache.drill | |
| 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.data | |
| org.apache.drill.exec.rpc.user | |
| org.apache.drill.exec.server.rest | |
| org.apache.drill.exec.server.rest.stream | |
| org.apache.drill.exec.store.parquet | |
| org.apache.drill.test |
Provides a variety of test framework tools to simplify Drill unit
tests and ad-hoc tests created while developing features.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SingleRowListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
| Modifier and Type | Class and Description |
|---|---|
class |
DrillClient
Thin wrapper around a UserClient that handles connect/close and transforms
String into ByteBuf.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LoggingResultsListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ClientConnection |
interface |
RemoteConnection |
interface |
ServerConnection<S extends ServerConnection<S>> |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractClientConnection |
class |
AbstractRemoteConnection |
class |
AbstractServerConnection<S extends ServerConnection<S>> |
| Modifier and Type | Class and Description |
|---|---|
class |
ControlConnection |
| Modifier and Type | Class and Description |
|---|---|
class |
DataClientConnection |
class |
DataServerConnection |
| Modifier and Type | Class and Description |
|---|---|
class |
UserClient.UserToBitConnection |
class |
UserServer.BitToUserConnection
Represents a client connection accepted by Foreman Drillbit's UserServer
from a DrillClient.
|
| Modifier and Type | Method and Description |
|---|---|
void |
QueryResultHandler.batchArrived(ConnectionThrottle throttle,
io.netty.buffer.ByteBuf pBody,
io.netty.buffer.ByteBuf dBody)
Maps internal low-level API protocol to
UserResultsListener-level API protocol. |
void |
AwaitableUserResultsListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
void |
UserResultsListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle)
A
QueryData message was received |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseWebUserConnection |
class |
WebUserConnection
WebUserConnectionWrapper which represents the UserClientConnection between
WebServer and Foreman, for the WebUser submitting the query. |
static class |
WebUserConnection.AnonWebUserConnection |
| Modifier and Type | Class and Description |
|---|---|
class |
StreamingHttpConnection
Stream the results of a query to a REST client as JSON, following the schema
defined by
QueryResult to maintain backward compatibility. |
| Modifier and Type | Method and Description |
|---|---|
void |
ParquetResultListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
| Modifier and Type | Method and Description |
|---|---|
void |
QueryBuilder.SummaryOnlyQueryEventListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
void |
PrintingResultsListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
void |
BaseTestQuery.SilentListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
void |
BufferingQueryEventListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.