schema_of_variant

Restituisce lo schema nel formato SQL di una variante.

Sintassi

from pyspark.sql import functions as sf

sf.schema_of_variant(v)

Parametri

Parametro	TIPO	Description
v	pyspark.sql.Column o str	Nome di colonna o colonna variante.

Restituzioni

pyspark.sql.Column: colonna stringa che rappresenta lo schema variant

Esempi

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

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