Utilisateur actuel

Renvoie la base de données actuelle.

Syntaxe

Python
from pyspark.sql import functions as sf

sf.current_user()

Exemple 1 : obtenir l'utilisateur actuel

Python
from pyspark.sql import functions as sf
spark.range(1).select(sf.current_user()).show()

Output
+--------------+
|current_user()|
+--------------+
| ruifeng.zheng|
+--------------+

Sur cette page