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