org.apache.flink.table.planner.delegation

Class PlannerContext

java.lang.Object

org.apache.flink.table.planner.delegation.PlannerContext

@Internal
public class PlannerContext
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
PlannerContext(boolean isBatchMode, TableConfig tableConfig, ModuleManager moduleManager, FunctionCatalog functionCatalog, CatalogManager catalogManager, org.apache.calcite.jdbc.CalciteSchema rootSchema, List<org.apache.calcite.plan.RelTraitDef> traitDefs, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
CalciteParser	createCalciteParser()
FlinkCalciteCatalogReader	createCatalogReader(boolean lenientCaseSensitivity)
org.apache.flink.table.planner.calcite.FlinkPlannerImpl	createFlinkPlanner()
org.apache.calcite.tools.FrameworkConfig	createFrameworkConfig()
FlinkRelBuilder	createRelBuilder()
org.apache.calcite.plan.RelOptCluster	getCluster()
org.apache.flink.table.planner.calcite.FlinkContext	getFlinkContext()
RexFactory	getRexFactory()
org.apache.flink.table.planner.calcite.FlinkTypeFactory	getTypeFactory()

Methods inherited from class java.lang.Object

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

Constructor Detail

PlannerContext

public PlannerContext(boolean isBatchMode,
                      TableConfig tableConfig,
                      ModuleManager moduleManager,
                      FunctionCatalog functionCatalog,
                      CatalogManager catalogManager,
                      org.apache.calcite.jdbc.CalciteSchema rootSchema,
                      List<org.apache.calcite.plan.RelTraitDef> traitDefs,
                      ClassLoader classLoader)

Method Detail

getRexFactory

public RexFactory getRexFactory()

createFrameworkConfig

public org.apache.calcite.tools.FrameworkConfig createFrameworkConfig()

getTypeFactory

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

getFlinkContext

public org.apache.flink.table.planner.calcite.FlinkContext getFlinkContext()

createRelBuilder

public FlinkRelBuilder createRelBuilder()

createFlinkPlanner

public org.apache.flink.table.planner.calcite.FlinkPlannerImpl createFlinkPlanner()

createCalciteParser

public CalciteParser createCalciteParser()

createCatalogReader

public FlinkCalciteCatalogReader createCatalogReader(boolean lenientCaseSensitivity)

getCluster

public org.apache.calcite.plan.RelOptCluster getCluster()