@Internal public class QueryOperationCatalogViewTable extends org.apache.flink.table.planner.plan.schema.FlinkTable implements org.apache.calcite.schema.TranslatableTable
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)
.
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.planner.plan.schema.FlinkTable |
copy(org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic) |
static QueryOperationCatalogViewTable |
createCalciteTable(QueryOperationCatalogView catalogView) |
QueryOperationCatalogView |
getCatalogView() |
org.apache.calcite.rel.type.RelDataType |
getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory) |
org.apache.flink.table.planner.plan.stats.FlinkStatistic |
getStatistic() |
org.apache.calcite.rel.RelNode |
toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context,
org.apache.calcite.plan.RelOptTable relOptTable) |
getSysEndFieldName, getSysStartFieldName
getJdbcTableType, isRolledUp, rolledUpColumnValidInsideAgg, unwrap
public static QueryOperationCatalogViewTable createCalciteTable(QueryOperationCatalogView catalogView)
public org.apache.calcite.rel.RelNode toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context, org.apache.calcite.plan.RelOptTable relOptTable)
toRel
in interface org.apache.calcite.schema.TranslatableTable
public org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
getRowType
in interface org.apache.calcite.schema.Table
public QueryOperationCatalogView getCatalogView()
public org.apache.flink.table.planner.plan.stats.FlinkStatistic getStatistic()
getStatistic
in interface org.apache.calcite.schema.Table
getStatistic
in class org.apache.flink.table.planner.plan.schema.FlinkTable
public org.apache.flink.table.planner.plan.schema.FlinkTable copy(org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)
copy
in class org.apache.flink.table.planner.plan.schema.FlinkTable
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.