parse_json

Analiza una columna que contiene una cadena JSON en .VariantType Produce una excepción si una cadena representa un valor JSON no válido.

Syntax

from pyspark.sql import functions as sf

sf.parse_json(col)

Parámetros

Parámetro	Tipo	Description
col	pyspark.sql.Column o str	Cadenas con formato JSON de nombre de columna o columna.

Devoluciones

pyspark.sql.Column: una nueva columna de VariantType.

Examples

from pyspark.sql import functions as sf
df = spark.createDataFrame([ {'json': '''{ "a" : 1 }'''} ])
df.select(sf.to_json(sf.parse_json(df.json))).collect()

[Row(to_json(parse_json(json))='{"a":1}')]