Package org.apache.beam.sdk.extensions.sql.meta.catalog

Interface Catalog

All Known Implementing Classes:
IcebergCatalog, InMemoryCatalog
@Internal public interface Catalog
Represents a named and configurable container for managing tables. Is defined with a type and configuration properties. Uses an underlying MetaStore to manage tables and table providers.

  • Field Details

  • Method Details

    • type

      String type()
      A type that defines this catalog.

    • metaStore

      MetaStore metaStore()
      The underlying MetaStore that actually manages tables.

    • currentDatabase

      @Nullable String currentDatabase()
      Produces the currently active database. Can be null if no database is active.
      Returns:
      the current active database

    • createDatabase

      boolean createDatabase(String databaseName)
      Creates a database with this name.
      Parameters:
      databaseName -
      Returns:
      true if the database was created, false otherwise.

    • listDatabases

      Set<String> listDatabases()
      Returns a set of existing databases accessible to this catalog.
      Returns:
      a set of existing database names

    • useDatabase

      void useDatabase(String databaseName)
      Switches to use the specified database.
      Parameters:
      databaseName -

    • dropDatabase

      boolean dropDatabase(String databaseName, boolean cascade)
      Drops the database with this name. If cascade is true, the catalog should first drop all tables contained in this database.
      Parameters:
      databaseName -
      cascade -
      Returns:
      true if the database was dropped, false otherwise.

    • name

      String name()
      The name of this catalog, specified by the user.

    • properties

      Map<String,String> properties()
      User-specified configuration properties.