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

Class CatalogManagerSchema

  • All Implemented Interfaces:
    org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
    public class CatalogManagerSchema
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 CatalogManager. This is typically the root node of a pipeline. Child schemas are of type CatalogSchema.

    • 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
      java.util.Collection<Catalog> catalogs()  
      JdbcConnection connection()  
      void createCatalog​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier catalogIdentifier, java.lang.String type, java.util.Map<java.lang.String,​java.lang.String> properties, boolean replace, boolean ifNotExists)  
      void dropCatalog​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier identifier, boolean ifExists)  
      CatalogSchema getCatalogSchema​(@Nullable java.lang.String catalog)  
      CatalogSchema getCatalogSchema​(TableName tablePath)
      Returns the CatalogSchema for the catalog referenced in this TableName.
      CatalogSchema getCurrentCatalogSchema()  
      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 org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema 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 table)  
      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()  
      void maybeRegisterProvider​(TableName path, java.lang.String type)  
      void removeAllPipelineOptions()  
      void removePipelineOption​(java.lang.String key)  
      void setPipelineOption​(java.lang.String key, java.lang.String value)  
      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 useCatalog​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier catalogIdentifier)  

      • 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

      • createCatalog

        public void createCatalog​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier catalogIdentifier,
                          java.lang.String type,
                          java.util.Map<java.lang.String,​java.lang.String> properties,
                          boolean replace,
                          boolean ifNotExists)

      • useCatalog

        public void useCatalog​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier catalogIdentifier)

      • dropCatalog

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

      • maybeRegisterProvider

        public void maybeRegisterProvider​(TableName path,
                                  java.lang.String type)

      • getTable

        public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Table getTable​(java.lang.String table)
        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

      • getCatalogSchema

        public CatalogSchema getCatalogSchema​(@Nullable java.lang.String catalog)

      • getCurrentCatalogSchema

        public CatalogSchema getCurrentCatalogSchema()

      • getSubSchema

        public @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema 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

      • catalogs

        public java.util.Collection<Catalog> catalogs()

      • setPipelineOption

        public void setPipelineOption​(java.lang.String key,
                              java.lang.String value)

      • removePipelineOption

        public void removePipelineOption​(java.lang.String key)

      • removeAllPipelineOptions

        public void removeAllPipelineOptions()

      • 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