Package org.apache.flink.table.calcite.bridge

Interface CalciteContext

  • All Superinterfaces:
    org.apache.flink.table.delegation.ParserFactory.Context
    @Internal
public interface CalciteContext
extends org.apache.flink.table.delegation.ParserFactory.Context
    To provide calcite context which is mainly used to create Calcite's RelNode. The context is provided by Flink's table planner.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      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.
      org.apache.calcite.tools.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.
      ClassLoader getClassLoader()
      Return the ClassLoader defined in TableEnvironment.
      org.apache.calcite.plan.RelOptCluster getCluster()
      Return the RelOptCluster provided by Flink's table planner.
      org.apache.flink.table.catalog.FunctionCatalog getFunctionCatalog()
      Return the FunctionCatalog defined in TableEnvironment.
      org.apache.flink.table.api.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 interface org.apache.flink.table.delegation.ParserFactory.Context

        getCatalogRegistry

    • Method Detail

      • createCatalogReader

        org.apache.calcite.prepare.CalciteCatalogReader createCatalogReader​(boolean lenientCaseSensitivity)
        Create an instance of CalciteCatalogReader provided by Flink's table planner.

      • getCluster

        org.apache.calcite.plan.RelOptCluster getCluster()
        Return the RelOptCluster provided by Flink's table planner.

      • createFrameworkConfig

        org.apache.calcite.tools.FrameworkConfig createFrameworkConfig()
        Create an instance of FrameworkConfig provided by Flink's table planner.

      • getTypeFactory

        org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()
        Return the RelDataTypeFactory provided by Flink's table planner.

      • createRelBuilder

        org.apache.calcite.tools.RelBuilder createRelBuilder()
        Create a builder for relational expressions provided by Flink's table planner.

      • getTableConfig

        org.apache.flink.table.api.TableConfig getTableConfig()
        Return the TableConfig defined in TableEnvironment.

      • getFunctionCatalog

        org.apache.flink.table.catalog.FunctionCatalog getFunctionCatalog()
        Return the FunctionCatalog defined in TableEnvironment.

      • createToRelContext

        org.apache.calcite.plan.RelOptTable.ToRelContext createToRelContext()
        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.