parse_json

Parsuje sloupec obsahující řetězec JSON do objektu VariantType. Vyvolá výjimku, pokud řetězec představuje neplatnou hodnotu JSON.

Syntaxe

from pyspark.sql import functions as sf

sf.parse_json(col)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column nebo str	Řetězce ve formátu JSON s názvem sloupce nebo sloupce.

Návraty

pyspark.sql.Column: nový sloupec 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}')]