Package org.apache.beam.sdk.extensions.sql.meta.provider.iceberg

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

public class IcebergCatalog
extends InMemoryCatalog

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalog

currentDatabase, tableProviders

Fields inherited from interface org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog

DEFAULT

Constructor Summary

Constructors

Constructor	Description
IcebergCatalog(String name, Map<String,String> properties)

Method Summary

Modifier and Type	Method	Description
boolean	createDatabase(String database)	Creates a database with this name.
boolean	databaseExists(String db)	Returns true if the database exists.
boolean	dropDatabase(String database, boolean cascade)	Drops the database with this name.
IcebergMetastore	metaStore(String db)	Returns the underlying MetaStore for this database.
String	type()	A type that defines this catalog.
void	useDatabase(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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

IcebergCatalog

public IcebergCatalog(String name,
 Map<String,String> properties)

Method Details

metaStore

public IcebergMetastore metaStore(String db)

Description copied from interface: Catalog

Returns the underlying MetaStore for this database. Creates a new MetaStore if one does not exist yet.

Specified by:

metaStore in interface Catalog

Overrides:

metaStore in class InMemoryCatalog

type

public String type()

Description copied from interface: Catalog

A type that defines this catalog.

Specified by:

type in interface Catalog

Overrides:

type in class InMemoryCatalog

createDatabase

public boolean createDatabase(String database)

Description copied from interface: Catalog

Creates a database with this name.

Specified by:

createDatabase in interface Catalog

Overrides:

createDatabase in class InMemoryCatalog

Parameters:

database -

Returns:

true if the database was created, false otherwise.

useDatabase

public void useDatabase(String database)

Description copied from interface: Catalog

Switches to use the specified database.

Specified by:

useDatabase in interface Catalog

Overrides:

useDatabase in class InMemoryCatalog

Parameters:

database -

databaseExists

public boolean databaseExists(String db)

Description copied from interface: Catalog

Returns true if the database exists.

Specified by:

databaseExists in interface Catalog

Overrides:

databaseExists in class InMemoryCatalog

dropDatabase

public boolean dropDatabase(String database,
 boolean cascade)

Description copied from interface: Catalog

Drops the database with this name. If cascade is true, the catalog should first drop all tables contained in this database.

Specified by:

dropDatabase in interface Catalog

Overrides:

dropDatabase in class InMemoryCatalog

Parameters:

database -

cascade -

Returns:

true if the database was dropped, false otherwise.