Class IcebergCatalog
java.lang.Object
org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog
org.apache.beam.sdk.extensions.sql.meta.provider.iceberg.IcebergCatalog
- All Implemented Interfaces:
Catalog
-
Field Summary
Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog
currentDatabase, tableProviders -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleancreateDatabase(String database) Creates a database with this name.booleandatabaseExists(String db) Returns true if the database exists.booleandropDatabase(String database, boolean cascade) Drops the database with this name.Returns the underlyingMetaStorefor this database.type()A type that defines this catalog.voiduseDatabase(String database) Switches to use the specified database.Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog
currentDatabase, name, properties, registerTableProvider, tableProviders, toString
-
Constructor Details
-
IcebergCatalog
-
-
Method Details
-
metaStore
Description copied from interface:CatalogReturns the underlyingMetaStorefor this database. Creates a newMetaStoreif one does not exist yet.- Specified by:
metaStorein interfaceCatalog- Overrides:
metaStorein classInMemoryCatalog
-
type
Description copied from interface:CatalogA type that defines this catalog.- Specified by:
typein interfaceCatalog- Overrides:
typein classInMemoryCatalog
-
createDatabase
Description copied from interface:CatalogCreates a database with this name.- Specified by:
createDatabasein interfaceCatalog- Overrides:
createDatabasein classInMemoryCatalog- Parameters:
database-- Returns:
- true if the database was created, false otherwise.
-
useDatabase
Description copied from interface:CatalogSwitches to use the specified database.- Specified by:
useDatabasein interfaceCatalog- Overrides:
useDatabasein classInMemoryCatalog- Parameters:
database-
-
databaseExists
Description copied from interface:CatalogReturns true if the database exists.- Specified by:
databaseExistsin interfaceCatalog- Overrides:
databaseExistsin classInMemoryCatalog
-
dropDatabase
Description copied from interface:CatalogDrops the database with this name. If cascade is true, the catalog should first drop all tables contained in this database.- Specified by:
dropDatabasein interfaceCatalog- Overrides:
dropDatabasein classInMemoryCatalog- Parameters:
database-cascade-- Returns:
- true if the database was dropped, false otherwise.
-