| Package | Description |
|---|---|
| org.apache.drill.exec.exception |
Execution-time exceptions.
|
| org.apache.drill.exec.planner.fragment | |
| org.apache.drill.exec.planner.sql | |
| org.apache.drill.exec.planner.sql.handlers | |
| org.apache.drill.exec.pop | |
| org.apache.drill.exec.rpc.control | |
| org.apache.drill.exec.work | |
| org.apache.drill.exec.work.foreman |
| Modifier and Type | Class and Description |
|---|---|
class |
OptimizerException |
| Modifier and Type | Method and Description |
|---|---|
void |
Fragment.addSendExchange(Exchange e,
Fragment sendingToFragment) |
Fragment |
MakeFragmentsVisitor.visitExchange(Exchange exchange,
Fragment receivingFragment) |
Fragment |
MakeFragmentsVisitor.visitOp(PhysicalOperator op,
Fragment value) |
| Modifier and Type | Class and Description |
|---|---|
class |
QueryInputException |
| Modifier and Type | Method and Description |
|---|---|
static PhysicalPlan |
DrillSqlWorker.getPlan(QueryContext context,
String sql)
Converts sql query string into query physical plan.
|
static PhysicalPlan |
DrillSqlWorker.getPlan(QueryContext context,
String sql,
Pointer<String> textPlan)
Converts sql query string into query physical plan.
|
| Modifier and Type | Method and Description |
|---|---|
PhysicalPlan |
UseSchemaHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
DropFunctionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Unregisters UDFs dynamically.
|
PhysicalPlan |
SetOptionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Handles
DrillSqlSetOption query |
PhysicalPlan |
RefreshMetadataHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
MetastoreDropTableMetadataHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
MetastoreAnalyzeTableHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ViewHandler.CreateView.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ViewHandler.DropView.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
abstract PhysicalPlan |
AbstractSqlHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
CreateTableHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ExplainHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ResetOptionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Handles
DrillSqlResetOption query |
PhysicalPlan |
CreateFunctionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Registers UDFs dynamically.
|
PhysicalPlan |
DescribeSchemaHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
AnalyzeTableHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ShowFilesHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
DefaultSqlHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
org.apache.calcite.sql.SqlNode |
ShowTablesHandler.rewrite(org.apache.calcite.sql.SqlNode sqlNode)
Rewrite the parse tree as SELECT ...
|
org.apache.calcite.sql.SqlNode |
ShowSchemasHandler.rewrite(org.apache.calcite.sql.SqlNode sqlNode)
Rewrite the parse tree as SELECT ...
|
org.apache.calcite.sql.SqlNode |
DescribeTableHandler.rewrite(org.apache.calcite.sql.SqlNode sqlNode)
Rewrite the parse tree as SELECT ...
|
org.apache.calcite.sql.SqlNode |
ExplainHandler.rewrite(org.apache.calcite.sql.SqlNode sqlNode) |
protected org.apache.calcite.sql.SqlNode |
DefaultSqlHandler.rewrite(org.apache.calcite.sql.SqlNode node)
Rewrite the parse tree.
|
static <T> T |
AbstractSqlHandler.unwrap(Object o,
Class<T> clazz) |
protected DefaultSqlHandler.ConvertedRelNode |
ShowTablesHandler.validateAndConvert(org.apache.calcite.sql.SqlNode sqlNode)
Rewritten SHOW TABLES query should be executed against root schema.
|
protected DefaultSqlHandler.ConvertedRelNode |
DefaultSqlHandler.validateAndConvert(org.apache.calcite.sql.SqlNode sqlNode) |
protected org.apache.calcite.util.Pair<org.apache.calcite.sql.SqlNode,org.apache.calcite.rel.type.RelDataType> |
DescribeTableHandler.validateNode(org.apache.calcite.sql.SqlNode sqlNode) |
protected org.apache.calcite.util.Pair<org.apache.calcite.sql.SqlNode,org.apache.calcite.rel.type.RelDataType> |
DefaultSqlHandler.validateNode(org.apache.calcite.sql.SqlNode sqlNode) |
| Modifier and Type | Method and Description |
|---|---|
void |
TestFragmenter.ensureOneFragment() |
void |
TestFragmenter.ensureThreeFragments() |
static Fragment |
PopUnitTestBase.getRootFragment(PhysicalPlanReader reader,
String file) |
static Fragment |
PopUnitTestBase.getRootFragmentFromPlanString(PhysicalPlanReader reader,
String planString) |
| Modifier and Type | Method and Description |
|---|---|
void |
WorkEventBus.addFragmentStatusListener(UserBitShared.QueryId queryId,
FragmentStatusListener listener) |
| Modifier and Type | Method and Description |
|---|---|
void |
QueryWorkUnit.applyPlan(PhysicalPlanReader reader) |
BitControl.PlanFragment |
QueryWorkUnit.MinorFragmentDefn.applyPlan(PhysicalPlanReader reader) |
| Modifier and Type | Class and Description |
|---|---|
class |
SqlUnsupportedException |
class |
UnsupportedDataTypeException |
class |
UnsupportedFunctionException |
class |
UnsupportedRelOperatorException |
Copyright © 2021 The Apache Software Foundation. All rights reserved.