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

Class ExpandingPreparingTable

java.lang.Object

org.apache.calcite.prepare.Prepare.AbstractPreparingTable

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

QueryOperationCatalogViewTable, SqlCatalogViewTable

public abstract class ExpandingPreparingTable
extends FlinkPreparingTableBase

A common subclass for all tables that are expanded to sub-query (views). It handles recursive expanding of sub-views automatically.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.plan.RelOptTable

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

Field Summary

Fields inherited from class org.apache.flink.table.planner.plan.schema.FlinkPreparingTableBase

names, relOptSchema, rowType, statistic

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ExpandingPreparingTable(org.apache.calcite.plan.RelOptSchema relOptSchema, org.apache.calcite.rel.type.RelDataType rowType, Iterable<String> names, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

Method Summary

Modifier and Type	Method and Description
protected abstract org.apache.calcite.rel.RelNode	convertToRel(org.apache.calcite.plan.RelOptTable.ToRelContext context) Converts the table to a RelNode.
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context)

Methods inherited from class 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

Methods inherited from class org.apache.calcite.prepare.Prepare.AbstractPreparingTable

extend, getColumnStrategies

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpandingPreparingTable

protected ExpandingPreparingTable(@Nullable
                                  org.apache.calcite.plan.RelOptSchema relOptSchema,
                                  org.apache.calcite.rel.type.RelDataType rowType,
                                  Iterable<String> names,
                                  org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

Method Detail

convertToRel

protected abstract org.apache.calcite.rel.RelNode convertToRel(org.apache.calcite.plan.RelOptTable.ToRelContext context)

Converts the table to a RelNode. Does not need to expand any nested scans of an ExpandingPreparingTable. Those will be expanded recursively.

Returns:

a relational tree

toRel

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

Specified by:

toRel in interface org.apache.calcite.plan.RelOptTable

Overrides:

toRel in class FlinkPreparingTableBase