Package org.apache.flink.table.planner.plan

Class FlinkCalciteCatalogReader

  • All Implemented Interfaces:
    org.apache.calcite.plan.RelOptSchema, org.apache.calcite.prepare.Prepare.CatalogReader, org.apache.calcite.schema.Wrapper, org.apache.calcite.sql.SqlOperatorTable, org.apache.calcite.sql.validate.SqlValidatorCatalogReader
    Direct Known Subclasses:
    FlinkCalciteCatalogSnapshotReader
    public class FlinkCalciteCatalogReader
extends org.apache.calcite.prepare.CalciteCatalogReader
    Flink specific CalciteCatalogReader that changes the RelOptTable which wrapped a CatalogSchemaTable to a FlinkPreparingTableBase.

    • Field Summary

      • Fields inherited from class org.apache.calcite.prepare.CalciteCatalogReader

        config, nameMatcher, rootSchema, typeFactory

      • Fields inherited from interface org.apache.calcite.prepare.Prepare.CatalogReader

        THREAD_LOCAL

    • Constructor Summary

      Constructors 
      Constructor Description
      FlinkCalciteCatalogReader​(org.apache.calcite.jdbc.CalciteSchema rootSchema, List<List<String>> defaultSchemas, org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.calcite.config.CalciteConnectionConfig config)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.calcite.prepare.Prepare.PreparingTable getTable​(List<String> names)  

      • Methods inherited from class org.apache.calcite.prepare.CalciteCatalogReader

        createTypeFromProjection, field, getAllSchemaObjectNames, getConfig, getNamedType, getOperatorList, getRootSchema, getSchemaPaths, getTableForMember, getTypeFactory, isCaseSensitive, lookupOperatorOverloads, matches, nameMatcher, operatorTable, registerRules, unwrap, withSchemaPath

      • Methods inherited from interface org.apache.calcite.schema.Wrapper

        maybeUnwrap, unwrapOrThrow

    • Constructor Detail

      • FlinkCalciteCatalogReader

        public FlinkCalciteCatalogReader​(org.apache.calcite.jdbc.CalciteSchema rootSchema,
                                 List<List<String>> defaultSchemas,
                                 org.apache.calcite.rel.type.RelDataTypeFactory typeFactory,
                                 org.apache.calcite.config.CalciteConnectionConfig config)

    • Method Detail

      • getTable

        public org.apache.calcite.prepare.Prepare.PreparingTable getTable​(List<String> names)
        Specified by:
        getTable in interface org.apache.calcite.prepare.Prepare.CatalogReader
        Specified by:
        getTable in interface org.apache.calcite.sql.validate.SqlValidatorCatalogReader
        Overrides:
        getTable in class org.apache.calcite.prepare.CalciteCatalogReader