to_timestamp_ltz(col, format=None)

Описание

Функция to_timestamp_ltz() преобразует строку в timestamp с учетом часового пояса (local time zone).

Параметры

col: Column - столбец со строкой для преобразования
format: String - формат даты и времени (опционально)

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

Timestamp - преобразованное значение даты и времени с учетом часового пояса

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

from pyspark.sql.functions import to_timestamp_ltz
from pyspark.sql import SparkSession

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

# Создаем DataFrame
data = [
    ("2023-01-01 12:00:00"),
    ("2023-02-01 15:30:00"),
    ("2023-03-01 18:45:00")
]
df = spark.createDataFrame(data, ["date_str"])

# Преобразуем строки в timestamp с учетом часового пояса
result = df.select(
    "date_str",
    to_timestamp_ltz("date_str").alias("timestamp_ltz")
).show()

# Результат:
# +-------------------+-------------------+
# |date_str           |timestamp_ltz      |
# +-------------------+-------------------+
# |2023-01-01 12:00:00|2023-01-01 12:00:00|
# |2023-02-01 15:30:00|2023-02-01 15:30:00|
# |2023-03-01 18:45:00|2023-03-01 18:45:00|
# +-------------------+-------------------+

Примечания

Для преобразования без учета часового пояса используйте to_timestamp()
Для преобразования в timestamp без часового пояса используйте to_timestamp_ntz()
Для преобразования в дату используйте to_date()
Для форматирования даты и времени используйте date_format()