org.apache.spark.sql.connector.catalog

Class Catalogs

Object

org.apache.spark.sql.connector.catalog.Catalogs

public class Catalogs
extends Object

Constructor Summary

Constructors

Constructor and Description
Catalogs()

Method Summary

Modifier and Type	Method and Description
static CatalogPlugin	load(String name, org.apache.spark.sql.internal.SQLConf conf) Load and configure a catalog by name.

Methods inherited from class Object

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

Constructor Detail

Catalogs

public Catalogs()

Method Detail

load

public static CatalogPlugin load(String name,
                                 org.apache.spark.sql.internal.SQLConf conf)
                          throws CatalogNotFoundException,
                                 SparkException

Load and configure a catalog by name.

This loads, instantiates, and initializes the catalog plugin for each call; it does not cache or reuse instances.

Parameters:

name - a String catalog name

conf - a SQLConf

Returns:

an initialized CatalogPlugin

Throws:

CatalogNotFoundException - if the plugin class cannot be found

SparkException - if the plugin class cannot be instantiated