current_catalog()

Описание

Функция current_catalog() возвращает имя текущего каталога в сессии Spark.

Параметры

Функция не принимает параметров.

Возвращаемое значение

String - имя текущего каталога

Пример использования

from pyspark.sql.functions import current_catalog
from pyspark.sql import SparkSession

# Создаем SparkSession
spark = SparkSession.builder.appName("current_catalog_example").getOrCreate()

# Получаем текущий каталог
result = spark.sql("SELECT current_catalog()").show()

# Результат:
# +----------------+
# |current_catalog()|
# +----------------+
# |spark_catalog   |
# +----------------+

Примечания

• По умолчанию возвращает "spark_catalog"
• Для работы с каталогами также используйте:
• current_database() для получения текущей базы данных
• current_schema() для получения текущей схемы
• current_user() для получения текущего пользователя