org.apache.flink.table.planner.plan

Class FlinkCalciteCatalogSnapshotReader

java.lang.Object

org.apache.calcite.prepare.CalciteCatalogReader

org.apache.flink.table.planner.plan.FlinkCalciteCatalogReader

org.apache.flink.table.planner.plan.FlinkCalciteCatalogSnapshotReader

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

public class FlinkCalciteCatalogSnapshotReader
extends FlinkCalciteCatalogReader

Extends FlinkCalciteCatalogReader to allow to read a snapshot of the CalciteSchema.

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
FlinkCalciteCatalogSnapshotReader(org.apache.calcite.sql.validate.SqlValidatorCatalogReader calciteCatalogReader, org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.calcite.schema.SchemaVersion schemaVersion)

Method Summary

Methods inherited from class org.apache.flink.table.planner.plan.FlinkCalciteCatalogReader

getTable

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

FlinkCalciteCatalogSnapshotReader

public FlinkCalciteCatalogSnapshotReader(org.apache.calcite.sql.validate.SqlValidatorCatalogReader calciteCatalogReader,
                                         org.apache.calcite.rel.type.RelDataTypeFactory typeFactory,
                                         org.apache.calcite.schema.SchemaVersion schemaVersion)