@Internal public class PlanningConfigurationBuilder extends Object
RelBuilder
or FrameworkConfig
used to create
a corresponding Planner
. It tries to separate static elements in a
TableEnvironment
like: root schema, cost factory, type system etc.
from a dynamic properties like e.g. default path to look for objects in the schema.Constructor and Description |
---|
PlanningConfigurationBuilder(TableConfig tableConfig,
FunctionCatalog functionCatalog,
org.apache.calcite.jdbc.CalciteSchema rootSchema,
org.apache.flink.table.expressions.ExpressionBridge<org.apache.flink.table.expressions.PlannerExpression> expressionBridge) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.calcite.FlinkPlannerImpl |
createFlinkPlanner(String currentCatalog,
String currentDatabase)
Creates a configured
FlinkPlannerImpl for a planning session. |
org.apache.flink.table.calcite.FlinkRelBuilder |
createRelBuilder(String currentCatalog,
String currentDatabase)
Creates a configured
FlinkRelBuilder for a planning session. |
org.apache.calcite.plan.Context |
getContext() |
org.apache.calcite.plan.RelOptPlanner |
getPlanner()
Returns the Calcite
RelOptPlanner that will be used. |
org.apache.calcite.sql.parser.SqlParser.Config |
getSqlParserConfig()
Returns the SQL parser config for this environment including a custom Calcite configuration.
|
org.apache.flink.table.calcite.FlinkTypeFactory |
getTypeFactory()
Returns the
FlinkTypeFactory that will be used. |
public PlanningConfigurationBuilder(TableConfig tableConfig, FunctionCatalog functionCatalog, org.apache.calcite.jdbc.CalciteSchema rootSchema, org.apache.flink.table.expressions.ExpressionBridge<org.apache.flink.table.expressions.PlannerExpression> expressionBridge)
public org.apache.flink.table.calcite.FlinkRelBuilder createRelBuilder(String currentCatalog, String currentDatabase)
FlinkRelBuilder
for a planning session.currentCatalog
- the current default catalog to look for first during planning.currentDatabase
- the current default database to look for first during planning.public org.apache.flink.table.calcite.FlinkPlannerImpl createFlinkPlanner(String currentCatalog, String currentDatabase)
FlinkPlannerImpl
for a planning session.currentCatalog
- the current default catalog to look for first during planning.currentDatabase
- the current default database to look for first during planning.public org.apache.calcite.plan.RelOptPlanner getPlanner()
RelOptPlanner
that will be used.public org.apache.flink.table.calcite.FlinkTypeFactory getTypeFactory()
FlinkTypeFactory
that will be used.public org.apache.calcite.plan.Context getContext()
public org.apache.calcite.sql.parser.SqlParser.Config getSqlParserConfig()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.