org.apache.flink.table.planner

Class PlanningConfigurationBuilder

java.lang.Object

org.apache.flink.table.planner.PlanningConfigurationBuilder

@Internal
public class PlanningConfigurationBuilder
extends Object

Utility class to create 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 Summary

Constructors

Constructor and Description
PlanningConfigurationBuilder(org.apache.flink.table.api.TableConfig tableConfig, org.apache.flink.table.catalog.FunctionCatalog functionCatalog, org.apache.calcite.jdbc.CalciteSchema rootSchema, org.apache.flink.table.expressions.ExpressionBridge<org.apache.flink.table.expressions.PlannerExpression> expressionBridge)

Method Summary

Modifier and Type	Method and Description
CalciteParser	createCalciteParser() Creates a configured instance of CalciteParser.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PlanningConfigurationBuilder

public PlanningConfigurationBuilder(org.apache.flink.table.api.TableConfig tableConfig,
                                    org.apache.flink.table.catalog.FunctionCatalog functionCatalog,
                                    org.apache.calcite.jdbc.CalciteSchema rootSchema,
                                    org.apache.flink.table.expressions.ExpressionBridge<org.apache.flink.table.expressions.PlannerExpression> expressionBridge)

Method Detail

createRelBuilder

public org.apache.flink.table.calcite.FlinkRelBuilder createRelBuilder(String currentCatalog,
                                                                       String currentDatabase)

Creates a configured FlinkRelBuilder for a planning session.

Parameters:

currentCatalog - the current default catalog to look for first during planning.

currentDatabase - the current default database to look for first during planning.

Returns:

configured rel builder

createFlinkPlanner

public org.apache.flink.table.calcite.FlinkPlannerImpl createFlinkPlanner(String currentCatalog,
                                                                          String currentDatabase)

Creates a configured FlinkPlannerImpl for a planning session.

Parameters:

currentCatalog - the current default catalog to look for first during planning.

currentDatabase - the current default database to look for first during planning.

Returns:

configured flink planner

createCalciteParser

public CalciteParser createCalciteParser()

Creates a configured instance of CalciteParser.

Returns:

configured calcite parser

getPlanner

public org.apache.calcite.plan.RelOptPlanner getPlanner()

Returns the Calcite RelOptPlanner that will be used.

getTypeFactory

public org.apache.flink.table.calcite.FlinkTypeFactory getTypeFactory()

Returns the FlinkTypeFactory that will be used.

getContext

public org.apache.calcite.plan.Context getContext()

getSqlParserConfig

public org.apache.calcite.sql.parser.SqlParser.Config getSqlParserConfig()

Returns the SQL parser config for this environment including a custom Calcite configuration.