org.apache.paimon.spark.catalog

Class SparkBaseCatalog

java.lang.Object

org.apache.paimon.spark.catalog.SparkBaseCatalog

All Implemented Interfaces:

ProcedureCatalog, WithPaimonCatalog, org.apache.spark.sql.connector.catalog.CatalogPlugin, org.apache.spark.sql.connector.catalog.SupportsNamespaces, org.apache.spark.sql.connector.catalog.TableCatalog

Direct Known Subclasses:

SparkCatalog, SparkGenericCatalog

public abstract class SparkBaseCatalog
extends Object
implements org.apache.spark.sql.connector.catalog.TableCatalog, org.apache.spark.sql.connector.catalog.SupportsNamespaces, ProcedureCatalog, WithPaimonCatalog

Spark base catalog.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	catalogName

Fields inherited from interface org.apache.spark.sql.connector.catalog.TableCatalog

OPTION_PREFIX, PROP_COMMENT, PROP_EXTERNAL, PROP_IS_MANAGED_LOCATION, PROP_LOCATION, PROP_OWNER, PROP_PROVIDER

Fields inherited from interface org.apache.spark.sql.connector.catalog.SupportsNamespaces

PROP_COMMENT, PROP_LOCATION, PROP_OWNER

Constructor Summary

Constructors

Constructor and Description
SparkBaseCatalog()

Method Summary

Modifier and Type	Method and Description
Procedure	loadProcedure(org.apache.spark.sql.connector.catalog.Identifier identifier) Loads a stored procedure by identifier.
String	name()
boolean	usePaimon(String provider)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.sql.connector.catalog.TableCatalog

alterTable, capabilities, createTable, createTable, dropTable, invalidateTable, listTables, loadTable, loadTable, loadTable, purgeTable, renameTable, tableExists, useNullableQuerySchema

Methods inherited from interface org.apache.spark.sql.connector.catalog.SupportsNamespaces

alterNamespace, createNamespace, dropNamespace, listNamespaces, listNamespaces, loadNamespaceMetadata, namespaceExists

Methods inherited from interface org.apache.spark.sql.connector.catalog.CatalogPlugin

defaultNamespace, initialize

Methods inherited from interface org.apache.paimon.spark.catalog.WithPaimonCatalog

paimonCatalog

Field Detail

catalogName

protected String catalogName

Constructor Detail

SparkBaseCatalog

public SparkBaseCatalog()

Method Detail

name

public String name()

Specified by:

name in interface org.apache.spark.sql.connector.catalog.CatalogPlugin

loadProcedure

public Procedure loadProcedure(org.apache.spark.sql.connector.catalog.Identifier identifier)
                        throws NoSuchProcedureException

Description copied from interface: ProcedureCatalog

Loads a stored procedure by identifier.

Specified by:

loadProcedure in interface ProcedureCatalog

Parameters:

identifier - A stored procedure identifier.

Returns:

The procedure's metadata of given identifier.

Throws:

NoSuchProcedureException - Thrown, if there is no matching procedure stored.

usePaimon

public boolean usePaimon(String provider)