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