Pular para o conteúdo principal

esquema_atual

Retorna o banco de dados atual.

Sintaxe

Python
from pyspark.sql import functions as sf

sf.current_schema()

Exemplos

Exemplo 1 : Obter o esquema atual

Python
from pyspark.sql import functions as sf
spark.range(1).select(sf.current_schema()).show()
Output
+----------------+
|current_schema()|
+----------------+
| default|
+----------------+