user()

Описание

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

Параметры

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

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

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

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

from pyspark.sql.functions import user
from pyspark.sql import SparkSession

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

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

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

Примечания

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