Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
JSON dizesi içeren bir sütunu içine ayrıştırıyor VariantType. Dize geçersiz bir JSON değeri içeriyorsa Hiçbiri döndürür.
Sözdizimi
from pyspark.sql import functions as sf
sf.try_parse_json(col)
Parametreler
| Parametre | Türü | Description |
|---|---|---|
col |
pyspark.sql.Column veya str |
Sütun veya sütun adı JSON biçimli dizeler. |
İade
pyspark.sql.Column: VariantType'ın yeni sütunu.
Örnekler
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)]