make_timestamp_ltz(year, month, day, hour, minute, second)
Описание
Функция make_timestamp_ltz()
создает метку времени с учетом локального часового пояса.
Параметры
year
: int - годmonth
: int - месяц (1-12)day
: int - день (1-31)hour
: int - час (0-23)minute
: int - минута (0-59)second
: int - секунда (0-59)
Возвращаемое значение
Column - метка времени с учетом локального часового пояса
Пример использования
from pyspark.sql.functions import make_timestamp_ltz
from pyspark.sql import SparkSession
# Создаем SparkSession
spark = SparkSession.builder.appName("make_timestamp_ltz_example").getOrCreate()
# Создаем DataFrame
data = [
(2023, 12, 25, 15, 30, 0),
(2024, 1, 1, 0, 0, 0),
(2023, 6, 15, 12, 0, 0)
]
df = spark.createDataFrame(data, ["year", "month", "day",
"hour", "minute", "second"])
# Создаем метки времени
df = df.withColumn("timestamp",
make_timestamp_ltz(col("year"), col("month"), col("day"),
col("hour"), col("minute"), col("second")))
df.show(truncate=False)
# Результат:
# +----+-----+---+----+------+------+-------------------+
# |year|month|day|hour|minute|second|timestamp |
# +----+-----+---+----+------+------+-------------------+
# |2023|12 |25 |15 |30 |0 |2023-12-25 15:30:00|
# |2024|1 |1 |0 |0 |0 |2024-01-01 00:00:00|
# |2023|6 |15 |12 |0 |0 |2023-06-15 12:00:00|
# +----+-----+---+----+------+------+-------------------+
Примечания
- Все параметры должны быть целыми числами
- Учитывает локальный часовой пояс
- Полезно для:
- Создания меток времени
- Работы с локальным временем
- Преобразования дат и времени
- Связанные функции:
make_timestamp_ntz()
- создание метки времени без учета часового поясаto_timestamp()
- преобразование в метку времениto_utc_timestamp()
- преобразование в UTC