parse_json

Анализирует столбец, содержащий строку JSON в объекте VariantType. Вызывает исключение, если строка представляет недопустимое значение JSON.

Синтаксис

from pyspark.sql import functions as sf

sf.parse_json(col)

Параметры

Параметр	Тип	Description
col	pyspark.sql.Column или str	Строки форматирования столбца или столбца JSON.

Возвраты

pyspark.sql.Column: новый столбец VariantType.

Примеры

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}')]