org.apache.flink.table.planner.plan

Class FlinkCalciteCatalogReader

java.lang.Object

org.apache.calcite.prepare.CalciteCatalogReader

org.apache.flink.table.planner.plan.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 and 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

Modifier and Type	Method and 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 class java.lang.Object

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

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