JSON 文字列を含む列を VariantTypeに解析します。 文字列に無効な JSON 値が含まれている場合は None を返します。
構文
from pyspark.sql import functions as sf
sf.try_parse_json(col)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
col |
pyspark.sql.Column または str |
JSON 形式の列または列名の文字列。 |
返品ポリシー
pyspark.sql.Column: VariantType の新しい列。
例示
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)]