try_parse_json

JSON 文字列を含む列をVariantTypeに解析します。文字列に無効な JSON 値が含まれている場合は None を返します。

構文

Python

from pyspark.sql import functions as sf

sf.try_parse_json(col)

パラメーター

パラメーター	Type	説明
col	pyspark.sql.Column または文字列	列または列名の JSON 形式の文字列。

戻り値

pyspark.sql.Column: VariantType の新しい列。

例

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