Skip to main content
Last updated on

schema_of_variant_agg

Returns the merged schema in the SQL format of a variant column.

Syntax​

Python
from pyspark.sql import functions as sf

sf.schema_of_variant_agg(v)

Parameters​

Parameter

Type

Description

v

pyspark.sql.Column or str

A variant column or column name.

Returns​

pyspark.sql.Column: a string column representing the variant schema

Examples​

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>')]