parse_json

Analizza una colonna contenente una stringa JSON in un oggetto VariantType. Genera un'eccezione se una stringa rappresenta un valore JSON non valido.

Sintassi

from pyspark.sql import functions as sf

sf.parse_json(col)

Parametri

Parametro	TIPO	Description
col	pyspark.sql.Column o str	Stringhe in formato JSON con nome di colonna o colonna.

Restituzioni

pyspark.sql.Column: nuova colonna di VariantType.

Esempi

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