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

Возвращает текущее время в начале вычисления запроса в качестве столбца TimeType. Все вызовы current_time в одном запросе возвращают одно и то же значение.

Синтаксис

from pyspark.sql import functions as dbf

dbf.current_time(precision=<precision>)

Параметры

Параметр	Тип	Description
precision	intнеобязательный	Число в диапазоне [0.6], указывающее, сколько дробных цифр секунд необходимо включить. Если опущено, значение по умолчанию равно 6.

Возвраты

pyspark.sql.Column: текущее время.

Примеры

Пример 1. Текущее время с точностью по умолчанию

from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time().alias("time")).show()

+---------------+
|           time|
+---------------+
|16:57:04.304361|
+---------------+

Пример 2. Текущее время с указанной точностью

from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time(3).alias("time")).show()

+------------+
|        time|
+------------+
|16:57:04.304|
+------------+