Title here
Summary here
weekofyear
weekofyear(col)
weekofyear - Функция weekofyear в PySpark используется для получения номера недели в году для заданной даты. Она принимает один параметр: date , который представляет собой столбец типа DateType или TimestampType.
Принято что неделя начинается с понедельника.
1 -й неделей в году считается неделя если в ней более чем 3 дня, согласно определению стандарта ISO 8601.
- Параметры
col: Column or str. Выражение или колонка с типом данных timestamp- Возвращает
ColumnНеделя года для переданной даты как целое число.
Пример
from pyspark.sql import SparkSession
from pyspark.sql.functions import weekofyear
spark = SparkSession.builder.getOrCreate()
data = [(1, '2023-01-01'),
(2, '2024-05-15'),
(3, '2012-12-31')]
df = spark.createDataFrame(data, ['id', 'date'])
df = df.withColumn('date', df['date'].cast('date'))
df = df.withColumn('week', weekofyear(df['date']))
df.show()
+---+----------+----+
| id| date|week|
+---+----------+----+
| 1|2023-01-01| 52|
| 2|2024-05-15| 20|
| 3|2012-12-31| 1|
+---+----------+----+
pyspark weekofyear
| Добавлено в версии | 1.5.0. |
| Обновлено в версии | 3.4.0. |