current_user()

Описание

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

Параметры

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

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

String - имя текущего пользователя

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

from pyspark.sql.functions import current_user
from pyspark.sql import SparkSession

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

# Получаем текущего пользователя
result = spark.sql("SELECT current_user()").show()

# Результат:
# +--------------+
# |current_user()|
# +--------------+
# |anonymous     |
# +--------------+

Примечания

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