year(date)

Описание

Функция year() извлекает год из даты или временной метки.

Параметры

• date: Column - столбец с датами или временными метками

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

Integer - год

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

from pyspark.sql.functions import year
from pyspark.sql import SparkSession
from datetime import datetime

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

# Создаем DataFrame с датами
data = [
    (datetime(2023, 1, 15),),
    (datetime(2024, 1, 15),),
    (datetime(2025, 1, 15),)
]
df = spark.createDataFrame(data, ["date"])

# Извлекаем год из каждой даты
result = df.select(
    "date",
    year("date").alias("year")
).show(truncate=False)

# Результат:
# +-------------------+----+
# |date               |year|
# +-------------------+----+
# |2023-01-15 00:00:00|2023|
# |2024-01-15 00:00:00|2024|
# |2025-01-15 00:00:00|2025|
# +-------------------+----+

Примечания

• NULL значения возвращают NULL
• Для работы с датами также используйте:
• month() для извлечения месяца
• day() для извлечения дня
• hour() для извлечения часа
• minute() для извлечения минут
• second() для извлечения секунд
• quarter() для извлечения квартала
• dayofweek() для извлечения дня недели
• dayofyear() для извлечения дня года
• weekofyear() для извлечения номера недели в году