schema_of_variant

Devuelve el esquema en formato SQL de una variante.

Syntax

from pyspark.sql import functions as sf

sf.schema_of_variant(v)

Parámetros

Parámetro	Tipo	Description
v	pyspark.sql.Column o str	Un nombre de columna o columna variant.

Devoluciones

pyspark.sql.Column: una columna de cadena que representa el esquema variant.

Examples

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