public abstract class SparkBaseCatalog extends Object implements org.apache.spark.sql.connector.catalog.TableCatalog, org.apache.spark.sql.connector.catalog.SupportsNamespaces, ProcedureCatalog, WithPaimonCatalog
Modifier and Type | Field and Description |
---|---|
protected String |
catalogName |
Constructor and Description |
---|
SparkBaseCatalog() |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
alterTable, capabilities, createTable, createTable, dropTable, invalidateTable, listTables, loadTable, loadTable, loadTable, loadTable, purgeTable, renameTable, tableExists, useNullableQuerySchema
alterNamespace, createNamespace, dropNamespace, listNamespaces, listNamespaces, loadNamespaceMetadata, namespaceExists
defaultNamespace, initialize
paimonCatalog
protected String catalogName
public String name()
name
in interface org.apache.spark.sql.connector.catalog.CatalogPlugin
public Procedure loadProcedure(org.apache.spark.sql.connector.catalog.Identifier identifier) throws NoSuchProcedureException
ProcedureCatalog
stored procedure
by identifier
.loadProcedure
in interface ProcedureCatalog
identifier
- A stored procedure identifier.NoSuchProcedureException
- Thrown, if there is no matching procedure stored.public boolean usePaimon(String provider)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.