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