current_schema()

Описание

Функция current_schema() возвращает имя текущей схемы в сессии Spark.

Параметры

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

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

String - имя текущей схемы

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

from pyspark.sql.functions import current_schema
from pyspark.sql import SparkSession

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

# Получаем текущую схему
result = spark.sql("SELECT current_schema()").show()

# Результат:
# +----------------+
# |current_schema()|
# +----------------+
# |default         |
# +----------------+

Примечания

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