SparkFunctionCatalog

java.lang.Object

org.apache.iceberg.spark.SparkFunctionCatalog

All Implemented Interfaces:: org.apache.spark.sql.connector.catalog.CatalogPlugin, org.apache.spark.sql.connector.catalog.FunctionCatalog

public class SparkFunctionCatalog extends Object

A function catalog that can be used to resolve Iceberg functions without a metastore connection.

Constructor Summary

Constructors

Constructor

Description

SparkFunctionCatalog()
Method Summary

Modifier and Type

Method

Description

static SparkFunctionCatalog

get()

void

initialize(String catalogName, org.apache.spark.sql.util.CaseInsensitiveStringMap options)

default boolean

isExistingNamespace(String[] namespace)

default boolean

isFunctionNamespace(String[] namespace)

default org.apache.spark.sql.connector.catalog.Identifier[]

listFunctions(String[] namespace)

default org.apache.spark.sql.connector.catalog.functions.UnboundFunction

loadFunction(org.apache.spark.sql.connector.catalog.Identifier ident)

String

name()

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.CatalogPlugin
defaultNamespace

Methods inherited from interface org.apache.spark.sql.connector.catalog.FunctionCatalog
functionExists

Constructor Details
- SparkFunctionCatalog
  
  public SparkFunctionCatalog()
Method Details
- get
  
  public static SparkFunctionCatalog get()
- initialize
  
  public void initialize(String catalogName, org.apache.spark.sql.util.CaseInsensitiveStringMap options)
  
  Specified by:
  
  initialize in interface org.apache.spark.sql.connector.catalog.CatalogPlugin
- name
  
  public String name()
  
  Specified by:
  
  name in interface org.apache.spark.sql.connector.catalog.CatalogPlugin
- isFunctionNamespace
  
  default boolean isFunctionNamespace(String[] namespace)
- isExistingNamespace
  
  default boolean isExistingNamespace(String[] namespace)
- listFunctions
  
  default org.apache.spark.sql.connector.catalog.Identifier[] listFunctions(String[] namespace) throws org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException
  
  Specified by:
  
  listFunctions in interface org.apache.spark.sql.connector.catalog.FunctionCatalog
  
  Throws:
  
  org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException
- loadFunction
  
  default org.apache.spark.sql.connector.catalog.functions.UnboundFunction loadFunction(org.apache.spark.sql.connector.catalog.Identifier ident) throws org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException
  
  Specified by:
  
  loadFunction in interface org.apache.spark.sql.connector.catalog.FunctionCatalog
  
  Throws:
  
  org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException