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, properties, 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> props)

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.
Collection<String>	databases()	Returns a collection of existing database names.
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	updateProperties(Map<String,String> setProps, Collection<String> resetProps)	Set some catalog properties.
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> props)

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

updateProperties

public void updateProperties(Map<String,String> setProps,
 Collection<String> resetProps)

Description copied from interface: Catalog

Set some catalog properties. If a property already exists, it will be overridden.

Specified by:

updateProperties in interface Catalog

Overrides:

updateProperties 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.

databases

public Collection<String> databases()

Description copied from interface: Catalog

Returns a collection of existing database names.

Specified by:

databases in interface Catalog

Overrides:

databases in class InMemoryCatalog

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.