schema_of_json

Parsuje řetězec JSON a odvodí jeho schéma ve formátu DDL.

Syntaxe

from pyspark.sql import functions as sf

sf.schema_of_json(json, options=None)

Parametry

Parameter	Typ	Description
json	pyspark.sql.Column nebo str	Řetězec JSON nebo skládací řetězec obsahující řetězec JSON.
options	diktování, volitelné	Možnosti pro kontrolu analýzy Přijímá stejné možnosti jako zdroj dat JSON.

Návraty

pyspark.sql.Column: Řetězcová StructType reprezentace parsovaného z daného formátu JSON.

Examples

import pyspark.sql.functions as sf
parsed1 = sf.schema_of_json(sf.lit('{"a": 0}'))
parsed2 = sf.schema_of_json('{a: 1}', {'allowUnquotedFieldNames':'true'})
spark.range(1).select(parsed1, parsed2).show()

+------------------------+----------------------+
|schema_of_json({"a": 0})|schema_of_json({a: 1})|
+------------------------+----------------------+
|       STRUCT<a: BIGINT>|     STRUCT<a: BIGINT>|
+------------------------+----------------------+