org.apache.flink.table.planner.delegation

Class DefaultCalciteContext

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.table.calcite.bridge.CalciteContext, org.apache.flink.table.delegation.ParserFactory.Context

@Internal
public class DefaultCalciteContext
extends Object
implements org.apache.flink.table.calcite.bridge.CalciteContext

A context for default dialect with calcite related interfaces.

Constructor Summary

Constructors

Constructor and Description
DefaultCalciteContext(org.apache.flink.table.catalog.CatalogManager catalogManager, PlannerContext plannerContext)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.prepare.CalciteCatalogReader	createCatalogReader(boolean lenientCaseSensitivity)
org.apache.calcite.tools.FrameworkConfig	createFrameworkConfig()
RelBuilder	createRelBuilder()
org.apache.calcite.plan.RelOptTable.ToRelContext	createToRelContext()
org.apache.flink.table.catalog.CatalogManager	getCatalogManager()
org.apache.flink.table.catalog.CatalogRegistry	getCatalogRegistry()
ClassLoader	getClassLoader()
org.apache.calcite.plan.RelOptCluster	getCluster()
org.apache.flink.table.catalog.FunctionCatalog	getFunctionCatalog()
PlannerContext	getPlannerContext()
org.apache.flink.table.api.TableConfig	getTableConfig()
org.apache.calcite.rel.type.RelDataTypeFactory	getTypeFactory()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCalciteContext

public DefaultCalciteContext(org.apache.flink.table.catalog.CatalogManager catalogManager,
                             PlannerContext plannerContext)

Method Detail

getPlannerContext

public PlannerContext getPlannerContext()

getCatalogManager

public org.apache.flink.table.catalog.CatalogManager getCatalogManager()

getCatalogRegistry

public org.apache.flink.table.catalog.CatalogRegistry getCatalogRegistry()

Specified by:

getCatalogRegistry in interface org.apache.flink.table.delegation.ParserFactory.Context

createCatalogReader

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

Specified by:

createCatalogReader in interface org.apache.flink.table.calcite.bridge.CalciteContext

getCluster

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

Specified by:

getCluster in interface org.apache.flink.table.calcite.bridge.CalciteContext

createFrameworkConfig

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

Specified by:

createFrameworkConfig in interface org.apache.flink.table.calcite.bridge.CalciteContext

getTypeFactory

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

Specified by:

getTypeFactory in interface org.apache.flink.table.calcite.bridge.CalciteContext

createRelBuilder

public RelBuilder createRelBuilder()

Specified by:

createRelBuilder in interface org.apache.flink.table.calcite.bridge.CalciteContext

getTableConfig

public org.apache.flink.table.api.TableConfig getTableConfig()

Specified by:

getTableConfig in interface org.apache.flink.table.calcite.bridge.CalciteContext

getClassLoader

public ClassLoader getClassLoader()

Specified by:

getClassLoader in interface org.apache.flink.table.calcite.bridge.CalciteContext

getFunctionCatalog

public org.apache.flink.table.catalog.FunctionCatalog getFunctionCatalog()

Specified by:

getFunctionCatalog in interface org.apache.flink.table.calcite.bridge.CalciteContext

createToRelContext

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

Specified by:

createToRelContext in interface org.apache.flink.table.calcite.bridge.CalciteContext