Skip to content

minute(timestamp)

Описание

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

Параметры

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

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

Integer - минуты из временной метки (от 0 до 59)

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

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

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

# Создаем DataFrame с временными метками
data = [
    (datetime(2023, 1, 1, 12, 0, 0),),   # 12:00
    (datetime(2023, 1, 1, 12, 30, 0),),  # 12:30
    (datetime(2023, 1, 1, 12, 59, 0),)   # 12:59
]
df = spark.createDataFrame(data, ["timestamp"])

# Извлекаем минуты из временных меток
result = df.select(
    "timestamp",
    minute("timestamp").alias("minute")
).show(truncate=False)

# Результат:
# +-------------------+------+
# |timestamp          |minute|
# +-------------------+------+
# |2023-01-01 12:00:00|0     |
# |2023-01-01 12:30:00|30    |
# |2023-01-01 12:59:00|59    |
# +-------------------+------+

Примечания

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