pyspark.sql.functions.current_schema

pyspark.sql.functions. 当前模式 ( ) → pyspark.sql.column.Column [source]

返回当前数据库。

新增于版本 3.5.0。

示例

>>> import pyspark.sql.functions as sf
>>> spark.range(1).select(sf.current_schema()).show()  
+------------------+
|current_database()|
+------------------+
|           default|
+------------------+