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. Genera un'eccezione se una stringa rappresenta un valore JSON non valido.
Sintassi
from pyspark.sql import functions as sf
sf.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 }'''} ])
df.select(sf.to_json(sf.parse_json(df.json))).collect()
[Row(to_json(parse_json(json))='{"a":1}')]