共用方式為


current_user

回傳目前的資料庫。

語法

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|
+--------------+