org.apache.flink.table.planner.plan.schema

类 CatalogSourceTable

java.lang.Object

org.apache.calcite.prepare.Prepare.AbstractPreparingTable

org.apache.flink.table.planner.plan.schema.FlinkPreparingTableBase

org.apache.flink.table.planner.plan.schema.CatalogSourceTable

所有已实现的接口:

org.apache.calcite.plan.RelOptTable, org.apache.calcite.prepare.Prepare.PreparingTable, org.apache.calcite.schema.Wrapper, org.apache.calcite.sql.validate.SqlValidatorTable

public final class CatalogSourceTable
extends FlinkPreparingTableBase

A FlinkPreparingTableBase implementation which defines the interfaces required to translate the Calcite RelOptTable to the Flink specific TableSourceTable.

This table is only used to translate the CatalogTable into TableSourceTable during the last phase of the SQL-to-rel conversion, it is not necessary anymore once the SQL node was converted to a relational expression.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.calcite.plan.RelOptTable

org.apache.calcite.plan.RelOptTable.ToRelContext, org.apache.calcite.plan.RelOptTable.ViewExpander

字段概要

从类继承的字段 org.apache.flink.table.planner.plan.schema.FlinkPreparingTableBase

names, relOptSchema, rowType, statistic

构造器概要

构造器

构造器和说明
CatalogSourceTable(org.apache.calcite.plan.RelOptSchema relOptSchema, List<String> names, org.apache.calcite.rel.type.RelDataType rowType, CatalogSchemaTable schemaTable)

方法概要

限定符和类型	方法和说明
static CatalogSourceTable	createAnonymous(FlinkRelBuilder relBuilder, org.apache.flink.table.catalog.ContextResolvedTable contextResolvedTable, boolean isBatchMode) Create a CatalogSourceTable from an anonymous ContextResolvedTable.
org.apache.flink.table.catalog.CatalogTable	getCatalogTable()
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext toRelContext)

从类继承的方法 org.apache.flink.table.planner.plan.schema.FlinkPreparingTableBase

columnHasDefaultValue, explainSourceAsString, extend, getAllowedAccess, getCollationList, getDistribution, getExpression, getKeys, getMonotonicity, getNames, getQualifiedName, getReferentialConstraints, getRelOptSchema, getRowCount, getRowType, getStatistic, isKey, isTemporal, supportsModality, uniqueKeysSet, unwrap

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

extend, getColumnStrategies

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

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

构造器详细资料

CatalogSourceTable

public CatalogSourceTable(org.apache.calcite.plan.RelOptSchema relOptSchema,
                          List<String> names,
                          org.apache.calcite.rel.type.RelDataType rowType,
                          CatalogSchemaTable schemaTable)

方法详细资料

createAnonymous

public static CatalogSourceTable createAnonymous(FlinkRelBuilder relBuilder,
                                                 org.apache.flink.table.catalog.ContextResolvedTable contextResolvedTable,
                                                 boolean isBatchMode)

Create a CatalogSourceTable from an anonymous ContextResolvedTable. This is required to manually create a preparing table skipping the calcite catalog resolution.

toRel

public org.apache.calcite.rel.RelNode toRel(org.apache.calcite.plan.RelOptTable.ToRelContext toRelContext)

指定者:

toRel 在接口中 org.apache.calcite.plan.RelOptTable

覆盖:

toRel 在类中 FlinkPreparingTableBase

getCatalogTable

public org.apache.flink.table.catalog.CatalogTable getCatalogTable()