Title here
Summary here
year(col)
year
- извлекает год из заданной даты или колонки с типом timestamp.
col
: Column or str. колонка или значение содержащая дату или timestampColumn
возвращает год как целое число.from pyspark.sql import SparkSession
from pyspark.sql.functions import to_date, year
# Создание сессии Spark
spark = SparkSession.builder.appName("years_example").getOrCreate()
# Пример данных
data = [("2022-01-01",)]
df = spark.createDataFrame(data, ["date_str"])
# Извлечения года из даты
df_with_subtracted_years = df.withColumn("year", year(col("date_str")))
# Отображение результата
df_with_subtracted_years.show(truncate=False)
pyspark year
Добавлено в версии | 1.5.0. |
Обновлено в версии | 3.4.0. |