parse_json

JSON-sztringet tartalmazó oszlop elemzése egy VariantType. Kivételt eredményez, ha egy sztring érvénytelen JSON-értéket jelöl.

Szemantika

from pyspark.sql import functions as sf

sf.parse_json(col)

Paraméterek

Paraméter	Típus	Description
col	pyspark.sql.Column vagy str	JSON formátumú karakterláncok oszlop- vagy oszlopneve.

Visszatérítések

pyspark.sql.Column: a VariantType új oszlopa.

Példák

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