Package org.apache.flink.table.planner.delegation

Class DefaultCalciteContext

java.lang.Object

org.apache.flink.table.planner.delegation.DefaultCalciteContext

All Implemented Interfaces:

CalciteContext, ParserFactory.Context

@Internal
public class DefaultCalciteContext
extends Object
implements CalciteContext

A context for default dialect with calcite related interfaces.

Constructor Summary

Constructors

Constructor	Description
DefaultCalciteContext(CatalogManager catalogManager, PlannerContext plannerContext)

Method Summary

Modifier and Type	Method	Description
org.apache.calcite.prepare.CalciteCatalogReader	createCatalogReader(boolean lenientCaseSensitivity)	Create an instance of CalciteCatalogReader provided by Flink's table planner.
org.apache.calcite.tools.FrameworkConfig	createFrameworkConfig()	Create an instance of FrameworkConfig provided by Flink's table planner.
RelBuilder	createRelBuilder()	Create a builder for relational expressions provided by Flink's table planner.
org.apache.calcite.plan.RelOptTable.ToRelContext	createToRelContext()	Create a new instance of RelOptTable.ToRelContext provided by Flink's table planner.
CatalogManager	getCatalogManager()
CatalogRegistry	getCatalogRegistry()
ClassLoader	getClassLoader()	Return the ClassLoader defined in TableEnvironment.
org.apache.calcite.plan.RelOptCluster	getCluster()	Return the RelOptCluster provided by Flink's table planner.
FunctionCatalog	getFunctionCatalog()	Return the FunctionCatalog defined in TableEnvironment.
PlannerContext	getPlannerContext()
TableConfig	getTableConfig()	Return the TableConfig defined in TableEnvironment.
org.apache.calcite.rel.type.RelDataTypeFactory	getTypeFactory()	Return the RelDataTypeFactory provided by Flink's table planner.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCalciteContext

public DefaultCalciteContext(CatalogManager catalogManager,
                             PlannerContext plannerContext)

Method Detail

getPlannerContext

public PlannerContext getPlannerContext()

getCatalogManager

public CatalogManager getCatalogManager()

getCatalogRegistry

public CatalogRegistry getCatalogRegistry()

Specified by:

getCatalogRegistry in interface ParserFactory.Context

createCatalogReader

public org.apache.calcite.prepare.CalciteCatalogReader createCatalogReader(boolean lenientCaseSensitivity)

Description copied from interface: CalciteContext

Create an instance of CalciteCatalogReader provided by Flink's table planner.

Specified by:

createCatalogReader in interface CalciteContext

getCluster

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

Description copied from interface: CalciteContext

Return the RelOptCluster provided by Flink's table planner.

Specified by:

getCluster in interface CalciteContext

createFrameworkConfig

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

Description copied from interface: CalciteContext

Create an instance of FrameworkConfig provided by Flink's table planner.

Specified by:

createFrameworkConfig in interface CalciteContext

getTypeFactory

public org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()

Description copied from interface: CalciteContext

Return the RelDataTypeFactory provided by Flink's table planner.

Specified by:

getTypeFactory in interface CalciteContext

createRelBuilder

public RelBuilder createRelBuilder()

Description copied from interface: CalciteContext

Create a builder for relational expressions provided by Flink's table planner.

Specified by:

createRelBuilder in interface CalciteContext

getTableConfig

public TableConfig getTableConfig()

Description copied from interface: CalciteContext

Return the TableConfig defined in TableEnvironment.

Specified by:

getTableConfig in interface CalciteContext

getClassLoader

public ClassLoader getClassLoader()

Description copied from interface: CalciteContext

Return the ClassLoader defined in TableEnvironment.

Specified by:

getClassLoader in interface CalciteContext

getFunctionCatalog

public FunctionCatalog getFunctionCatalog()

Description copied from interface: CalciteContext

Return the FunctionCatalog defined in TableEnvironment.

Specified by:

getFunctionCatalog in interface CalciteContext

createToRelContext

public org.apache.calcite.plan.RelOptTable.ToRelContext createToRelContext()

Description copied from interface: CalciteContext

Create a new instance of RelOptTable.ToRelContext provided by Flink's table planner. The RelOptTable.ToRelContext is used to convert a table into a relational expression.

Specified by:

createToRelContext in interface CalciteContext