Skip to content

current_database()

Описание

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

Параметры

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

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

String - имя текущей базы данных

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

from pyspark.sql.functions import current_database
from pyspark.sql import SparkSession

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

# Получаем текущую базу данных
result = spark.sql("SELECT current_database()").show()

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

Примечания

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