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

Class BeamSystemTableMetadataSchema

java.lang.Object
org.apache.beam.sdk.extensions.sql.impl.BeamSystemTableMetadataSchema
All Implemented Interfaces:
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
public class BeamSystemTableMetadataSchema extends Object implements org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
A Calcite Schema responsible for SHOW TABLES requests.

  • Method Details

    • getTable

      public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Table getTable(String dbName)
      Specified by:
      getTable 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

    • getSubSchema

      public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema getSubSchema(@Nullable String catalogName)
      Specified by:
      getSubSchema 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

    • getTypeNames

      public Set<String> getTypeNames()
      Specified by:
      getTypeNames 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 s)
      Specified by:
      getType 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 s)
      Specified by:
      getFunctions 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

    • getExpression

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

    • 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 schemaVersion)
      Specified by:
      snapshot in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema