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|
# +----+-----+---+----+------+------+-------------------+