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

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	dropDatabase(String database, boolean cascade)	Drops the database with this name.
Set<String>	listDatabases()	Returns a set of existing databases accessible to this catalog.
InMemoryMetaStore	metaStore()	The underlying MetaStore that actually manages tables.
String	type()	A type that defines this catalog.

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

currentDatabase, name, properties, useDatabase

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergCatalog

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

Method Details

metaStore

public InMemoryMetaStore metaStore()

Description copied from interface: Catalog

The underlying MetaStore that actually manages tables.

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.

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.

listDatabases

public Set<String> listDatabases()

Description copied from interface: Catalog

Returns a set of existing databases accessible to this catalog.

Specified by:

listDatabases in interface Catalog

Overrides:

listDatabases in class InMemoryCatalog

Returns:

a set of existing database names