Package 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
    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, String tableName)
     
    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, List<String> updateColumnList, 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 Details

    • 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, String tableName)
      Specified by:
      asQueryable in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.QueryableTable

    • getModifiableCollection

      public 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, List<String> updateColumnList, 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