aktuální čas

Vrátí aktuální čas na začátku vyhodnocení dotazu jako sloupec TimeType. Všechna volání current_time ve stejném dotazu vrátí stejnou hodnotu.

Syntaxe

from pyspark.sql import functions as dbf

dbf.current_time(precision=<precision>)

Parametry

Parameter Typ Description
precision intvolitelný Číslo v rozsahu [0,,6], určující počet desetinných číslic sekund, které se mají zahrnout. Pokud tento parametr vynecháte, výchozí hodnota je 6.

Návraty

pyspark.sql.Column: Aktuální čas.

Examples

Příklad 1: Aktuální čas s výchozí přesností

from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time().alias("time")).show()
+---------------+
|           time|
+---------------+
|16:57:04.304361|
+---------------+

Příklad 2: Aktuální čas se zadanou přesností

from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time(3).alias("time")).show()
+------------+
|        time|
+------------+
|16:57:04.304|
+------------+