org.apache.flink.table.planner.plan

类 FlinkCalciteCatalogReader

java.lang.Object

org.apache.calcite.prepare.CalciteCatalogReader

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

所有已实现的接口:

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 FlinkCalciteCatalogReader
extends org.apache.calcite.prepare.CalciteCatalogReader

Flink specific CalciteCatalogReader that changes the RelOptTable which wrapped a CatalogSchemaTable to a FlinkPreparingTableBase.

字段概要

从类继承的字段 org.apache.calcite.prepare.CalciteCatalogReader

config, nameMatcher, rootSchema, typeFactory

从接口继承的字段 org.apache.calcite.prepare.Prepare.CatalogReader

THREAD_LOCAL

构造器概要

构造器

构造器和说明
FlinkCalciteCatalogReader(org.apache.calcite.jdbc.CalciteSchema rootSchema, List<List<String>> defaultSchemas, org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.calcite.config.CalciteConnectionConfig config)

方法概要

限定符和类型	方法和说明
org.apache.calcite.prepare.Prepare.PreparingTable	getTable(List<String> names)

从类继承的方法 org.apache.calcite.prepare.CalciteCatalogReader

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

从类继承的方法 java.lang.Object

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

构造器详细资料

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)

方法详细资料

getTable

public org.apache.calcite.prepare.Prepare.PreparingTable getTable(List<String> names)

指定者:

getTable 在接口中 org.apache.calcite.prepare.Prepare.CatalogReader

指定者:

getTable 在接口中 org.apache.calcite.sql.validate.SqlValidatorCatalogReader

覆盖:

getTable 在类中 org.apache.calcite.prepare.CalciteCatalogReader