Anmerkung
Der Zugriff auf diese Seite erfordert eine Genehmigung. Du kannst versuchen, dich anzumelden oder die Verzeichnisse zu wechseln.
Der Zugriff auf diese Seite erfordert eine Genehmigung. Du kannst versuchen , die Verzeichnisse zu wechseln.
Analysiert eine Spalte, die eine JSON-Zeichenfolge enthält, in eine VariantType. Gibt None zurück, wenn eine Zeichenfolge einen ungültigen JSON-Wert enthält.
Syntax
from pyspark.sql import functions as sf
sf.try_parse_json(col)
Die Parameter
| Parameter | Typ | Description |
|---|---|---|
col |
pyspark.sql.Column oder str |
Eine json-formatierte JSON-Formatierte Zeichenfolgen für Spalten oder Spalten. |
Rückkehr
pyspark.sql.Column: eine neue Spalte von VariantType.
Examples
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)]