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

Class CatalogSchema

  • All Implemented Interfaces:
    org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
    public class CatalogSchema
extends java.lang.Object
implements org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
    A Calcite Schema that corresponds to a Catalog. Child schemas are of type BeamCalciteSchema.

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

        org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema.TableType

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void createDatabase​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier databaseIdentifier, boolean ifNotExists)  
      void dropDatabase​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier, boolean cascade, boolean ifExists)  
      Catalog getCatalog()  
      @Nullable BeamCalciteSchema getCurrentDatabaseSchema()  
      BeamCalciteSchema getDatabaseSchema​(TableName tablePath)  
      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, java.lang.String s)  
      java.util.Set<java.lang.String> getFunctionNames()  
      java.util.Collection<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Function> getFunctions​(java.lang.String s)  
      @Nullable BeamCalciteSchema getSubSchema​(@Nullable java.lang.String name)  
      java.util.Set<java.lang.String> getSubSchemaNames()  
      @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Table getTable​(java.lang.String s)  
      java.util.Set<java.lang.String> getTableNames()  
      @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.type.RelProtoDataType getType​(java.lang.String s)  
      java.util.Set<java.lang.String> getTypeNames()  
      boolean isMutable()  
      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)  
      void useDatabase​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier)  

      • 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_40_0.org.apache.calcite.schema.Schema

        subSchemas, tables

    • Method Detail

      • getCatalog

        public Catalog getCatalog()

      • getCurrentDatabaseSchema

        public @Nullable BeamCalciteSchema getCurrentDatabaseSchema()

      • createDatabase

        public void createDatabase​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier databaseIdentifier,
                           boolean ifNotExists)

      • useDatabase

        public void useDatabase​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier)

      • dropDatabase

        public void dropDatabase​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier,
                         boolean cascade,
                         boolean ifExists)

      • getTable

        public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Table getTable​(java.lang.String s)
        Specified by:
        getTable in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

      • getTableNames

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

      • getSubSchema

        public @Nullable BeamCalciteSchema getSubSchema​(@Nullable java.lang.String name)
        Specified by:
        getSubSchema in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

      • getSubSchemaNames

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

      • getTypeNames

        public java.util.Set<java.lang.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​(java.lang.String s)
        Specified by:
        getType in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

      • getFunctions

        public java.util.Collection<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Function> getFunctions​(java.lang.String s)
        Specified by:
        getFunctions in interface org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema

      • getFunctionNames

        public java.util.Set<java.lang.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,
                                                                                                      java.lang.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