다음을 통해 공유


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