schema_of_variant_agg

Vrátí sloučené schéma ve formátu SQL ve sloupci varianty.

Syntaxe

from pyspark.sql import functions as sf

sf.schema_of_variant_agg(v)

Parametry

Parameter	Typ	Description
v	pyspark.sql.Column nebo str	Název sloupce nebo sloupce varianty.

Návraty

pyspark.sql.Column: Řetězcový sloupec představující schéma varianty

Examples

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()

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