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

Class CatalogManagerSchema

java.lang.Object
org.apache.beam.sdk.extensions.sql.impl.CatalogManagerSchema
All Implemented Interfaces:
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.Schema
public class CatalogManagerSchema extends 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.

  • Method Details

    • connection

      public JdbcConnection connection()

    • createCatalog

      public void createCatalog(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.SqlIdentifier catalogIdentifier, String type, Map<String,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, String type)

    • getTable

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

    • getCatalogSchema

      public CatalogSchema getCatalogSchema(TableName tablePath)

    • getCurrentCatalogSchema

      public CatalogSchema getCurrentCatalogSchema()

    • getSubSchema

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

    • setPipelineOption

      public void setPipelineOption(String key, String value)

    • removePipelineOption

      public void removePipelineOption(String key)

    • removeAllPipelineOptions

      public void removeAllPipelineOptions()

    • 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