public class RelTable
extends org.apache.calcite.schema.impl.AbstractTable
implements org.apache.calcite.schema.TranslatableTable
Table
implementation for registering
Table API Tables in the Calcite schema to be used by Flink SQL.
It implements TranslatableTable
so that its logical scan
can be converted to a relational expression.
DataSetTable
Constructor and Description |
---|
RelTable(org.apache.calcite.rel.RelNode relNode) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.schema.Schema.TableType |
getJdbcTableType() |
org.apache.calcite.rel.type.RelDataType |
getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory) |
org.apache.calcite.rel.RelNode |
toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context,
org.apache.calcite.plan.RelOptTable relOptTable) |
public org.apache.calcite.schema.Schema.TableType getJdbcTableType()
getJdbcTableType
in interface org.apache.calcite.schema.Table
getJdbcTableType
in class org.apache.calcite.schema.impl.AbstractTable
public org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
getRowType
in interface org.apache.calcite.schema.Table
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
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.