Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Parsar en kolumn som innehåller en JSON-sträng i en VariantType. Genererar undantag om en sträng representerar ett ogiltigt JSON-värde.
Syntax
from pyspark.sql import functions as sf
sf.parse_json(col)
Parameterar
| Parameter | Typ | Description |
|---|---|---|
col |
pyspark.sql.Column eller str |
En kolumn eller kolumn som heter JSON-formaterade strängar. |
Retur
pyspark.sql.Column: en ny kolumn i VariantType.
Examples
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}')]