Compartir a través de

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>')]
  • Last updated on