try_parse_json

Analyse une colonne contenant une chaîne JSON en VariantType. Renvoie None si une chaîne contient une valeur JSON non valide.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.try_parse_json(col)

parameter

parameter	Type	Description
col	pyspark.sql.Column ou str	Chaînes formatées JSON d'une colonne ou d'un nom de colonne.

parameter	Type	Description
col	pyspark.sql.Column ou str	Chaînes formatées JSON d'une colonne ou d'un nom de colonne.

Renvoie

pyspark.sql.Column: une nouvelle colonne de type VariantType.

Exemples

Python

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

Output

[Row(to_json(try_parse_json(json))='{"a":1}'), Row(to_json(try_parse_json(json))=None)]