try_parse_json

Analizuje kolumnę zawierającą ciąg JSON w obiekcie VariantType. Zwraca wartość Brak, jeśli ciąg zawiera nieprawidłową wartość JSON.

Składnia

from pyspark.sql import functions as sf

sf.try_parse_json(col)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column lub str	Ciągi sformatowane w formacie JSON w kolumnie lub kolumnie.

Zwraca

pyspark.sql.Column: nowa kolumna VariantType.

Przykłady

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()

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