heure actuelle
Renvoie l'heure actuelle au start de l'évaluation de la requête, sous forme de colonne de type Time. Tous les appels de current_time au sein de la même query renvoient la même valeur.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.current_time(precision=<precision>)
parameter
parameter | Type | Description |
|---|---|---|
|
| Nombre dans la plage [0..6], indiquant le nombre de chiffres fractionnaires de secondes à inclure. Si cette option est omise, la valeur par default est 6. |
Renvoie
pyspark.sql.Column: Heure actuelle.
Exemples
Exemple 1 : Heure actuelle avec une précision default.
Python
from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time().alias("time")).show()
Output
+---------------+
| time|
+---------------+
|16:57:04.304361|
+---------------+
Exemple 2 : Heure actuelle avec une précision spécifiée.
Python
from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time(3).alias("time")).show()
Output
+------------+
| time|
+------------+
|16:57:04.304|
+------------+