| Package | Description |
|---|---|
| org.apache.drill.exec.opt | |
| org.apache.drill.exec.physical | |
| org.apache.drill.exec.planner | |
| org.apache.drill.exec.planner.common | |
| org.apache.drill.exec.planner.physical | |
| org.apache.drill.exec.planner.sql | |
| org.apache.drill.exec.planner.sql.handlers | |
| org.apache.drill.exec.util | |
| org.apache.drill.exec.work.foreman.rm |
Provides resource management and queuing support for the Drill foreman.
|
| Modifier and Type | Method and Description |
|---|---|
abstract PhysicalPlan |
Optimizer.optimize(Optimizer.OptimizationContext context,
LogicalPlan plan) |
PhysicalPlan |
IdentityOptimizer.optimize(Optimizer.OptimizationContext context,
LogicalPlan plan) |
PhysicalPlan |
BasicOptimizer.optimize(Optimizer.OptimizationContext context,
LogicalPlan plan) |
| Modifier and Type | Method and Description |
|---|---|
static PhysicalPlan |
PhysicalPlan.parse(com.fasterxml.jackson.databind.ObjectReader reader,
String planString)
Parses a physical plan.
|
| Modifier and Type | Method and Description |
|---|---|
PhysicalPlan |
PhysicalPlanReader.readPhysicalPlan(String json) |
| Modifier and Type | Method and Description |
|---|---|
static PhysicalPlan |
DrillStatsTable.direct(QueryContext context,
boolean outcome,
String message,
Object... values) |
static PhysicalPlan |
DrillStatsTable.notRequired(QueryContext context,
String tbl) |
static PhysicalPlan |
DrillStatsTable.notSupported(QueryContext context,
String tbl) |
| Modifier and Type | Method and Description |
|---|---|
PhysicalPlan |
PhysicalPlanCreator.build(Prel rootPrel,
boolean forceRebuild) |
| Modifier and Type | Method and Description |
|---|---|
static <T> PhysicalPlan |
DirectPlan.createDirectPlan(CoordinationProtos.DrillbitEndpoint endpoint,
List<T> records,
Class<T> clazz) |
static PhysicalPlan |
DirectPlan.createDirectPlan(QueryContext context,
boolean result,
String message) |
static <T> PhysicalPlan |
DirectPlan.createDirectPlan(QueryContext context,
T obj) |
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 |
|---|---|
protected PhysicalPlan |
DefaultSqlHandler.convertToPlan(PhysicalOperator op) |
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 |
SchemaHandler.Create.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
SchemaHandler.Drop.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
SchemaHandler.Describe.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
SchemaHandler.Add.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
PhysicalPlan |
SchemaHandler.Remove.getPlan(org.apache.calcite.sql.SqlNode sqlNode) |
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 |
DropTableHandler.getPlan(org.apache.calcite.sql.SqlNode sqlNode)
Function resolves the schema and invokes the drop method
(while IF EXISTS statement is used function invokes the drop method only if table exists).
|
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) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultSqlHandler.log(String name,
PhysicalPlan plan,
org.slf4j.Logger logger) |
| Constructor and Description |
|---|
PhysicalExplain(org.apache.calcite.rel.RelNode node,
PhysicalPlan plan,
org.apache.calcite.sql.SqlExplainLevel level,
QueryContext context) |
| Modifier and Type | Method and Description |
|---|---|
static void |
MemoryAllocationUtilities.setupBufferedMemoryAllocations(PhysicalPlan plan,
QueryContext queryContext) |
| Modifier and Type | Field and Description |
|---|---|
protected PhysicalPlan |
ThrottledResourceManager.QueuedResourceAllocator.plan |
| Modifier and Type | Method and Description |
|---|---|
void |
ThrottledResourceManager.QueuedResourceAllocator.visitAbstractPlan(PhysicalPlan plan) |
void |
DefaultResourceManager.DefaultResourceAllocator.visitAbstractPlan(PhysicalPlan plan) |
void |
QueryResourceAllocator.visitAbstractPlan(PhysicalPlan plan)
Make any needed adjustments to the query plan before parallelization.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.