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

Class BeamCalciteSchema

java.lang.Object
org.apache.beam.sdk.extensions.sql.impl.BeamCalciteSchema
All Implemented Interfaces:
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
public class BeamCalciteSchema extends Object implements org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
A Calcite Schema that corresponds to a TableProvider or MetaStore. In Beam SQL, a DATABASE refers to a BeamCalciteSchema.

  • Method Details

    • name

      public String name()

    • getTableProvider

      public TableProvider getTableProvider()

    • getPipelineOptions

      public Map<String,String> getPipelineOptions()

    • setPipelineOption

      public void setPipelineOption(String key, String value)

    • removePipelineOption

      public void removePipelineOption(String key)

    • removeAllPipelineOptions

      public void removeAllPipelineOptions()

    • isMutable

      public boolean isMutable()
      Specified by:
      isMutable in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • snapshot

      public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema snapshot(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaVersion version)
      Specified by:
      snapshot in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getExpression

      public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaPlus parentSchema, String name)
      Specified by:
      getExpression in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getTableNames

      public Set<String> getTableNames()
      Specified by:
      getTableNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getType

      public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.type.RelProtoDataType getType(String name)
      Specified by:
      getType in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getTypeNames

      public Set<String> getTypeNames()
      Specified by:
      getTypeNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getTable

      public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Table getTable(String name)
      Specified by:
      getTable in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getFunctionNames

      public Set<String> getFunctionNames()
      Specified by:
      getFunctionNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getFunctions

      public Collection<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Function> getFunctions(String name)
      Specified by:
      getFunctions in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getSubSchemaNames

      public Set<String> getSubSchemaNames()
      Specified by:
      getSubSchemaNames in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

    • getSubSchema

      public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema getSubSchema(String name)
      If this is the root schema (in other words, a CatalogManager), the sub schema will be a Catalog's metastore.

      Otherwise, the sub-schema is derived from the TableProvider implementation.

      Specified by:
      getSubSchema in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema