Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Analizza una colonna contenente una stringa JSON in un oggetto VariantType. Restituisce Nessuno se una stringa contiene un valore JSON non valido.
Sintassi
from pyspark.sql import functions as sf
sf.try_parse_json(col)
Parametri
| Parametro | TIPO | Description |
|---|---|---|
col |
pyspark.sql.Column o str |
Stringhe in formato JSON con nome di colonna o colonna. |
Restituzioni
pyspark.sql.Column: nuova colonna di VariantType.
Esempi
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)]