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

Class BeamCalciteTable

java.lang.Object

org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.impl.AbstractTable

org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.adapter.java.AbstractQueryableTable

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

All Implemented Interfaces:

org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.ModifiableTable, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.QueryableTable, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Table, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.TranslatableTable, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Wrapper

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

Adapter from BeamSqlTable to a calcite Table.

Field Summary

Fields inherited from class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.adapter.java.AbstractQueryableTable

elementType

Method Summary

Modifier and Type	Method and Description
<T> org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.linq4j.Queryable<T>	asQueryable(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.linq4j.QueryProvider queryProvider, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.SchemaPlus schema, java.lang.String tableName)
java.util.Collection	getModifiableCollection()
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType	getRowType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
BeamTableStatistics	getStatistic()
static BeamCalciteTable	of(BeamSqlTable table)
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.core.TableModify	toModificationRel(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptCluster cluster, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptTable table, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.prepare.Prepare.CatalogReader catalogReader, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode child, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.core.TableModify.Operation operation, java.util.List<java.lang.String> updateColumnList, java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> sourceExpressionList, boolean flattened)
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.RelNode	toRel(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptTable.ToRelContext context, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptTable relOptTable)

Methods inherited from class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.adapter.java.AbstractQueryableTable

getElementType, getExpression

Methods inherited from class org.apache.beam.vendor.calcite.v1_28_0.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.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.QueryableTable

getElementType, getExpression

Methods inherited from interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Table

getJdbcTableType, isRolledUp, rolledUpColumnValidInsideAgg

Methods inherited from interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Wrapper

maybeUnwrap, unwrapOrThrow

Method Detail

of

public static BeamCalciteTable of(BeamSqlTable table)

getRowType

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

Specified by:

getRowType in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Table

getStatistic

public BeamTableStatistics getStatistic()

Specified by:

getStatistic in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Table

Overrides:

getStatistic in class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.impl.AbstractTable

toRel

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

Specified by:

toRel in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.TranslatableTable

asQueryable

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

Specified by:

asQueryable in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.QueryableTable

getModifiableCollection

public java.util.Collection getModifiableCollection()

Specified by:

getModifiableCollection in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.ModifiableTable

toModificationRel

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

Specified by:

toModificationRel in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.ModifiableTable