localtimestamp()

Описание

Функция localtimestamp() возвращает текущую локальную метку времени без учета часового пояса.

Параметры

Функция не принимает параметров.

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

Column - текущая локальная метка времени

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

from pyspark.sql.functions import localtimestamp
from pyspark.sql import SparkSession

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

# Создаем DataFrame
data = [
    (1,),
    (2,),
    (3,)
]
df = spark.createDataFrame(data, ["id"])

# Добавляем текущую локальную метку времени
df = df.withColumn("current_time", localtimestamp())
df.show(truncate=False)

# Результат:
# +---+-----------------------+
# |id |current_time          |
# +---+-----------------------+
# |1  |2023-12-20 15:30:45.123|
# |2  |2023-12-20 15:30:45.123|
# |3  |2023-12-20 15:30:45.123|
# +---+-----------------------+

Примечания

• Возвращает одинаковое значение для всех строк в одном запросе
• Не учитывает часовой пояс
• Полезно для:
• Отметки времени создания записей
• Логирования событий
• Аудита изменений
• Связанные функции:
• current_timestamp() - текущая метка времени
• now() - текущая дата и время
• current_date() - текущая дата