current_time()

Описание

Функция current_time() возвращает текущее время в формате TimeType.

Параметры

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

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

Time - текущее время

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

from pyspark.sql import SparkSession
from pyspark.sql.functions import current_time

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

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

# Добавляем текущее время
result = df.select(
    "id",
    current_time().alias("current_time")
).show()

# Результат:
# +---+------------+
# | id|current_time|
# +---+------------+
# |  1|    12:34:56|
# |  2|    12:34:56|
# |  3|    12:34:56|
# +---+------------+

Примечания

Функция возвращает время в формате 'HH:mm:ss'
Для получения текущей даты используйте current_date()
Для получения текущей даты и времени используйте current_timestamp()
Для форматирования времени используйте date_format()
Для работы с временными интервалами используйте datediff() или timestampdiff()