schema_of_json

Bir JSON dizesini ayrıştırıp şemasını DDL biçiminde çıkartır.

Sözdizimi

from pyspark.sql import functions as sf

sf.schema_of_json(json, options=None)

Parametreler

Parametre	Türü	Description
json	pyspark.sql.Column veya str	JSON dizesi veya JSON dizesi içeren katlanabilir dize sütunu.
options	dict, isteğe bağlı	Ayrıştırma denetimi seçenekleri. JSON veri kaynağıyla aynı seçenekleri kabul eder.

İade

pyspark.sql.Column: verilen JSON'dan ayrıştırılan bir StructType dize gösterimi.

Örnekler

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>|
+------------------------+----------------------+