org.apache.beam.sdk.extensions.sql.impl

Class BeamCalciteTable

java.lang.Object

org.apache.calcite.schema.impl.AbstractTable

org.apache.calcite.adapter.java.AbstractQueryableTable

org.apache.beam.sdk.extensions.sql.impl.BeamCalciteTable

All Implemented Interfaces:

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

public class BeamCalciteTable
extends org.apache.calcite.adapter.java.AbstractQueryableTable
implements org.apache.calcite.schema.ModifiableTable, org.apache.calcite.schema.TranslatableTable

Adapter from BeamSqlTable to a calcite Table.

Field Summary

Fields inherited from class org.apache.calcite.adapter.java.AbstractQueryableTable

elementType

Method Summary

Modifier and Type	Method and Description
<T> org.apache.calcite.linq4j.Queryable<T>	asQueryable(org.apache.calcite.linq4j.QueryProvider queryProvider, org.apache.calcite.schema.SchemaPlus schema, java.lang.String tableName)
java.util.Collection	getModifiableCollection()
org.apache.calcite.rel.type.RelDataType	getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
static BeamCalciteTable	of(BeamSqlTable table)
org.apache.calcite.rel.core.TableModify	toModificationRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelOptTable table, org.apache.calcite.prepare.Prepare.CatalogReader catalogReader, org.apache.calcite.rel.RelNode child, org.apache.calcite.rel.core.TableModify.Operation operation, java.util.List<java.lang.String> updateColumnList, java.util.List<org.apache.calcite.rex.RexNode> sourceExpressionList, boolean flattened)
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.adapter.java.AbstractQueryableTable

getElementType, getExpression

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

getJdbcTableType, getStatistic, 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.QueryableTable

getElementType, getExpression

Methods inherited from interface org.apache.calcite.schema.Table

getJdbcTableType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

Method Detail

of

public static BeamCalciteTable of(BeamSqlTable table)

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

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

asQueryable

public <T> org.apache.calcite.linq4j.Queryable<T> asQueryable(org.apache.calcite.linq4j.QueryProvider queryProvider,
                                                              org.apache.calcite.schema.SchemaPlus schema,
                                                              java.lang.String tableName)

Specified by:

asQueryable in interface org.apache.calcite.schema.QueryableTable

getModifiableCollection

public java.util.Collection getModifiableCollection()

Specified by:

getModifiableCollection in interface org.apache.calcite.schema.ModifiableTable

toModificationRel

public org.apache.calcite.rel.core.TableModify toModificationRel(org.apache.calcite.plan.RelOptCluster cluster,
                                                                 org.apache.calcite.plan.RelOptTable table,
                                                                 org.apache.calcite.prepare.Prepare.CatalogReader catalogReader,
                                                                 org.apache.calcite.rel.RelNode child,
                                                                 org.apache.calcite.rel.core.TableModify.Operation operation,
                                                                 java.util.List<java.lang.String> updateColumnList,
                                                                 java.util.List<org.apache.calcite.rex.RexNode> sourceExpressionList,
                                                                 boolean flattened)

Specified by:

toModificationRel in interface org.apache.calcite.schema.ModifiableTable