esquema_de_variante

Retorna o esquema no formato SQL de uma variante.

Sintaxe

Python

from pyspark.sql import functions as sf

sf.schema_of_variant(v)

Parâmetros

Parâmetro	Tipo	Descrição
v	pyspark.sql.Column ou str	Uma coluna variante ou um nome de coluna.

Devoluções

pyspark.sql.Column: uma coluna de strings representando o esquema variante

Exemplos

Python

from pyspark.sql import functions as sf
df = spark.createDataFrame([ {'json': '''{ "a" : 1 }'''} ])
df.select(sf.schema_of_variant(sf.parse_json(df.json)).alias("r")).collect()

Output

[Row(r='OBJECT<a: BIGINT>')]