| Package | Description |
|---|---|
| com.mapr.drill.maprdb.tests.json | |
| 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.user | |
| org.apache.drill.exec.store.parquet | |
| org.apache.drill.hbase | |
| 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 |
|---|---|
protected List<QueryDataBatch> |
BaseJsonTest.runHBaseSQLlWithResults(String sql) |
| Modifier and Type | Method and Description |
|---|---|
void |
SingleRowListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
protected abstract void |
SingleRowListener.rowArrived(QueryDataBatch queryDataBatch)
A record has arrived and is ready for access.
|
| Modifier and Type | Method and Description |
|---|---|
List<QueryDataBatch> |
DrillClient.executePreparedStatement(UserProtos.PreparedStatementHandle preparedStatementHandle)
Execute the given prepared statement and return the results.
|
List<QueryDataBatch> |
DrillClient.runQuery(UserBitShared.QueryType type,
String plan)
Submits a string based query plan for execution and returns the result batches.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LoggingResultsListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
| Modifier and Type | Method and Description |
|---|---|
void |
AwaitableUserResultsListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
void |
UserResultsListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle)
A
QueryData message was received |
| Modifier and Type | Method and Description |
|---|---|
void |
ParquetResultListener.dataArrived(QueryDataBatch result,
ConnectionThrottle throttle) |
| Modifier and Type | Method and Description |
|---|---|
protected List<QueryDataBatch> |
BaseHBaseTest.runHBaseSQLlWithResults(String sql) |
| Modifier and Type | Field and Description |
|---|---|
QueryDataBatch |
BufferingQueryEventListener.QueryEvent.batch |
| Modifier and Type | Method and Description |
|---|---|
List<QueryDataBatch> |
QueryBuilder.results()
Run the query and return a list of the result batches.
|
protected static List<QueryDataBatch> |
BaseTestQuery.testLogicalWithResults(String logical) |
protected static List<QueryDataBatch> |
BaseTestQuery.testPhysicalWithResults(String physical) |
static List<QueryDataBatch> |
BaseTestQuery.testPreparedStatement(UserProtos.PreparedStatementHandle handle) |
static List<QueryDataBatch> |
BaseTestQuery.testRunAndReturn(UserBitShared.QueryType type,
Object query) |
List<QueryDataBatch> |
BaseTestQuery.ClassicTestServices.testRunAndReturn(UserBitShared.QueryType type,
Object query) |
List<QueryDataBatch> |
ClusterFixture.FixtureTestServices.testRunAndReturn(UserBitShared.QueryType type,
Object query) |
List<QueryDataBatch> |
DrillTestWrapper.TestServices.testRunAndReturn(UserBitShared.QueryType type,
Object query) |
protected static List<QueryDataBatch> |
BaseTestQuery.testSqlWithResults(String sql) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
static void |
DrillTestWrapper.addToMaterializedResults(List<Map<String,Object>> materializedRecords,
List<QueryDataBatch> records,
RecordBatchLoader loader) |
int |
ClientFixture.countResults(List<QueryDataBatch> results) |
protected static String |
BaseTestQuery.getResultString(List<QueryDataBatch> results,
String delimiter) |
protected int |
BaseTestQuery.logResult(List<QueryDataBatch> results) |
protected int |
BaseTestQuery.printResult(List<QueryDataBatch> results) |
| Constructor and Description |
|---|
QueryEvent(QueryDataBatch batch) |
| Constructor and Description |
|---|
TestResultSet(List<QueryDataBatch> batches) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.