org.apache.iceberg.spark

Class SparkFunctionCatalog

java.lang.Object

org.apache.iceberg.spark.SparkFunctionCatalog

public class SparkFunctionCatalog
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
SparkFunctionCatalog()

Method Summary

Modifier and Type	Method and Description
static SparkFunctionCatalog	get()
void	initialize(java.lang.String catalogName, org.apache.spark.sql.util.CaseInsensitiveStringMap options)
default boolean	isExistingNamespace(java.lang.String[] namespace)
default boolean	isFunctionNamespace(java.lang.String[] namespace)
default org.apache.spark.sql.connector.catalog.Identifier[]	listFunctions(java.lang.String[] namespace)
default org.apache.spark.sql.connector.catalog.functions.UnboundFunction	loadFunction(org.apache.spark.sql.connector.catalog.Identifier ident)
java.lang.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.FunctionCatalog

functionExists

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

defaultNamespace

Constructor Detail

SparkFunctionCatalog

public SparkFunctionCatalog()

Method Detail

get

public static SparkFunctionCatalog get()

initialize

public void initialize(java.lang.String catalogName,
                       org.apache.spark.sql.util.CaseInsensitiveStringMap options)

name

public java.lang.String name()

isFunctionNamespace

public boolean isFunctionNamespace(java.lang.String[] namespace)

isExistingNamespace

public boolean isExistingNamespace(java.lang.String[] namespace)

listFunctions

public org.apache.spark.sql.connector.catalog.Identifier[] listFunctions(java.lang.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

public 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