Skip to content

current_timezone()

Описание

Функция current_timezone() возвращает текущий часовой пояс сессии Spark.

Параметры

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

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

Column - строка с идентификатором текущего часового пояса

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

from pyspark.sql.functions import current_timezone
from pyspark.sql import SparkSession

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

# Получаем текущий часовой пояс
result = spark.sql("SELECT current_timezone() as timezone")
result.show(truncate=False)

# Результат:
# +-----------+
# |timezone   |
# +-----------+
# |UTC        |
# +-----------+

Примечания

  • Возвращает строку с идентификатором часового пояса (например, "UTC", "America/New_York")
  • Часовой пояс можно изменить с помощью параметра spark.sql.session.timeZone
  • Полезно для:
  • Определения текущего часового пояса
  • Преобразования времени между часовыми поясами
  • Настройки временных меток
  • Связанные функции:
  • from_utc_timestamp() - преобразование из UTC
  • to_utc_timestamp() - преобразование в UTC