回傳目前的資料庫。
語法
from pyspark.sql import functions as sf
sf.current_user()
範例
範例 1:取得目前使用者
from pyspark.sql import functions as sf
spark.range(1).select(sf.current_user()).show()
+--------------+
|current_user()|
+--------------+
| ruifeng.zheng|
+--------------+