schema_of_json

Mengurai string JSON dan menyimpulkan skemanya dalam format DDL.

Syntax

from pyspark.sql import functions as sf

sf.schema_of_json(json, options=None)

Parameter-parameternya

Pengaturan	Tipe	Description
json	pyspark.sql.Column atau str	String JSON atau kolom string yang dapat dilipat yang berisi string JSON.
options	dict, opsional	Opsi untuk mengontrol penguraian. Menerima opsi yang sama dengan sumber data JSON.

Pengembalian Barang

pyspark.sql.Column: representasi string dari yang StructType diurai dari JSON tertentu.

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