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.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 |
---|---|
abstract PhysicalPlan |
AbstractSqlHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
CreateFunctionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Registers UDFs dynamically.
|
PhysicalPlan |
DropFunctionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Unregisters UDFs dynamically.
|
PhysicalPlan |
MetastoreDropTableMetadataHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
RefreshMetadataHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
DescribeSchemaHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
CreateAliasHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
DropAliasHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
DropAllAliasesHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ShowFilesHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ResetOptionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Handles
DrillSqlResetOption query |
PhysicalPlan |
SetOptionHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Handles
DrillSqlSetOption query |
PhysicalPlan |
UseSchemaHandler.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) |
PhysicalPlan |
AnalyzeTableHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
CreateTableHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
DefaultSqlHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
ExplainHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
MetastoreAnalyzeTableHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
protected org.apache.calcite.sql.SqlNode |
DefaultSqlHandler.rewrite(org.apache.calcite.sql.SqlNode node)
Rewrite the parse tree.
|
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) |
org.apache.calcite.sql.SqlNode |
ShowSchemasHandler.rewrite(org.apache.calcite.sql.SqlNode sqlNode)
Rewrite the parse tree as SELECT ...
|
org.apache.calcite.sql.SqlNode |
ShowTablesHandler.rewrite(org.apache.calcite.sql.SqlNode sqlNode)
Rewrite the parse tree as SELECT ...
|
static <T> T |
AbstractSqlHandler.unwrap(Object o,
Class<T> clazz) |
protected DefaultSqlHandler.ConvertedRelNode |
DefaultSqlHandler.validateAndConvert(org.apache.calcite.sql.SqlNode sqlNode) |
protected DefaultSqlHandler.ConvertedRelNode |
ShowTablesHandler.validateAndConvert(org.apache.calcite.sql.SqlNode sqlNode)
Rewritten SHOW TABLES query should be executed against root schema.
|
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) |
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) |
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 © 1970 The Apache Software Foundation. All rights reserved.