public class TransStreamTable
extends org.apache.calcite.schema.impl.AbstractTable
implements org.apache.calcite.schema.TranslatableTable, org.apache.calcite.schema.StreamableTable
Table
implementation for registering
Streaming 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 and StreamableTable
so that it can be used in Streaming SQL queries.
DataStreamTable
Modifier and Type | Class and Description |
---|---|
class |
TransStreamTable.StreamTable
Wraps a
TransStreamTable 's relNode
to implement its stream() method. |
Constructor and Description |
---|
TransStreamTable(org.apache.calcite.rel.RelNode relNode,
boolean wrapper) |
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.schema.Table |
stream() |
org.apache.calcite.rel.RelNode |
toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context,
org.apache.calcite.plan.RelOptTable relOptTable) |
public TransStreamTable(org.apache.calcite.rel.RelNode relNode, boolean wrapper)
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.schema.Table stream()
stream
in interface org.apache.calcite.schema.StreamableTable
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.