parse_json

Analyse une colonne contenant une chaîne JSON dans un VariantType. Lève une exception si une chaîne représente une valeur JSON non valide.

Syntaxe

from pyspark.sql import functions as sf

sf.parse_json(col)

Paramètres

Paramètre	Type	Descriptif
col	pyspark.sql.Column ou str	Chaînes au format JSON d’une colonne ou d’une colonne.

Retours

pyspark.sql.Column: nouvelle colonne 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}')]