dayofyear(date)
Описание
Функция dayofyear()
извлекает день года из даты или временной метки.
Параметры
date
: Column - столбец с датами или временными метками
Возвращаемое значение
Integer - день года из даты или временной метки (от 1 до 366)
Пример использования
from pyspark.sql.functions import dayofyear
from pyspark.sql import SparkSession
from datetime import datetime
# Создаем SparkSession
spark = SparkSession.builder.appName("dayofyear_example").getOrCreate()
# Создаем DataFrame с датами
data = [
(datetime(2023, 1, 1),), # 1-й день года
(datetime(2023, 2, 1),), # 32-й день года
(datetime(2023, 12, 31),) # 365-й день года
]
df = spark.createDataFrame(data, ["date"])
# Извлекаем день года из дат
result = df.select(
"date",
dayofyear("date").alias("day_of_year")
).show(truncate=False)
# Результат:
# +-------------------+------------+
# |date |day_of_year|
# +-------------------+------------+
# |2023-01-01 00:00:00|1 |
# |2023-02-01 00:00:00|32 |
# |2023-12-31 00:00:00|365 |
# +-------------------+------------+
Примечания
- NULL значения возвращают NULL
- В високосные годы максимальное значение - 366
- Для работы с датами также используйте:
year()
для извлечения годаmonth()
для извлечения месяцаday()
для извлечения дняhour()
для извлечения часаminute()
для извлечения минутsecond()
для извлечения секундquarter()
для извлечения кварталаdayofweek()
для извлечения дня недели