org.apache.iceberg.catalog

Class BaseSessionCatalog

java.lang.Object

org.apache.iceberg.catalog.BaseSessionCatalog

All Implemented Interfaces:

SessionCatalog

Direct Known Subclasses:

RESTSessionCatalog

public abstract class BaseSessionCatalog
extends java.lang.Object
implements SessionCatalog

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BaseSessionCatalog.AsCatalog

Nested classes/interfaces inherited from interface org.apache.iceberg.catalog.SessionCatalog

SessionCatalog.SessionContext

Constructor Summary

Constructors

Constructor and Description
BaseSessionCatalog()

Method Summary

Modifier and Type	Method and Description
Catalog	asCatalog(SessionCatalog.SessionContext context)
void	initialize(java.lang.String catalogName, java.util.Map<java.lang.String,java.lang.String> props) Initialize given a custom name and a map of catalog properties.
java.lang.String	name() Return the name for this catalog.
java.util.Map<java.lang.String,java.lang.String>	properties() Return the properties for this catalog.
<T> T	withContext(SessionCatalog.SessionContext context, java.util.function.Function<Catalog,T> task)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.catalog.SessionCatalog

buildTable, createNamespace, createNamespace, dropNamespace, dropTable, invalidateTable, listNamespaces, listNamespaces, listTables, loadNamespaceMetadata, loadTable, namespaceExists, purgeTable, registerTable, renameTable, tableExists, updateNamespaceMetadata

Constructor Detail

BaseSessionCatalog

public BaseSessionCatalog()

Method Detail

initialize

public void initialize(java.lang.String catalogName,
                       java.util.Map<java.lang.String,java.lang.String> props)

Description copied from interface: SessionCatalog

Initialize given a custom name and a map of catalog properties.

Specified by:

initialize in interface SessionCatalog

Parameters:

catalogName - a custom name for the catalog

props - catalog properties

name

public java.lang.String name()

Description copied from interface: SessionCatalog

Return the name for this catalog.

Specified by:

name in interface SessionCatalog

Returns:

this catalog's name

properties

public java.util.Map<java.lang.String,java.lang.String> properties()

Description copied from interface: SessionCatalog

Return the properties for this catalog.

Specified by:

properties in interface SessionCatalog

Returns:

this catalog's config properties

asCatalog

public Catalog asCatalog(SessionCatalog.SessionContext context)

withContext

public <T> T withContext(SessionCatalog.SessionContext context,
                         java.util.function.Function<Catalog,T> task)