org.apache.flink.table.catalog

Class QueryOperationCatalogViewTable

java.lang.Object

org.apache.calcite.schema.impl.AbstractTable

org.apache.flink.table.catalog.QueryOperationCatalogViewTable

All Implemented Interfaces:

org.apache.calcite.schema.Table, org.apache.calcite.schema.TranslatableTable, org.apache.calcite.schema.Wrapper

@Internal
public class QueryOperationCatalogViewTable
extends org.apache.calcite.schema.impl.AbstractTable
implements org.apache.calcite.schema.TranslatableTable

A bridge between a Flink's specific QueryOperationCatalogView and a Calcite's Table. It implements TranslatableTable interface. This enables direct translation from QueryOperation to RelNode.

NOTE: Due to legacy inconsistency in null handling in the TableSchema the translation might introduce additional cast to comply with manifested schema in getRowType(RelDataTypeFactory).

Method Summary

Modifier and Type	Method and Description
static QueryOperationCatalogViewTable	createCalciteTable(org.apache.flink.table.catalog.QueryOperationCatalogView catalogView, org.apache.flink.table.api.TableSchema resolvedSchema)
org.apache.calcite.rel.type.RelDataType	getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
org.apache.calcite.schema.Statistic	getStatistic()
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context, org.apache.calcite.plan.RelOptTable relOptTable)

Methods inherited from class org.apache.calcite.schema.impl.AbstractTable

getJdbcTableType, isRolledUp, rolledUpColumnValidInsideAgg, unwrap

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.Table

getJdbcTableType, isRolledUp, rolledUpColumnValidInsideAgg

Method Detail

getStatistic

public org.apache.calcite.schema.Statistic getStatistic()

Specified by:

getStatistic in interface org.apache.calcite.schema.Table

Overrides:

getStatistic in class org.apache.calcite.schema.impl.AbstractTable

createCalciteTable

public static QueryOperationCatalogViewTable createCalciteTable(org.apache.flink.table.catalog.QueryOperationCatalogView catalogView,
                                                                org.apache.flink.table.api.TableSchema resolvedSchema)

toRel

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

Specified by:

toRel in interface org.apache.calcite.schema.TranslatableTable

getRowType

public org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)

Specified by:

getRowType in interface org.apache.calcite.schema.Table