schema_of_variant_agg

Renvoie le schéma fusionné au format SQL d'une colonne de variante.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.schema_of_variant_agg(v)

parameter

parameter	Type	Description
v	pyspark.sql.Column ou str	Une colonne variante ou un nom de colonne.

parameter	Type	Description
v	pyspark.sql.Column ou str	Une colonne variante ou un nom de colonne.

Renvoie

pyspark.sql.Column: une colonne de type chaîne représentant le schéma de variante

Exemples

Python

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

Output

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