Bagikan melalui


json_object_keys

Mengembalikan semua kunci objek JSON terluar sebagai array. Jika objek JSON yang valid diberikan, semua kunci objek terluar akan dikembalikan sebagai array. Jika itu adalah string JSON lain yang valid, string JSON yang tidak valid atau string kosong, fungsi mengembalikan null.

Syntax

from pyspark.sql import functions as sf

sf.json_object_keys(col)

Parameter-parameternya

Pengaturan Tipe Description
col pyspark.sql.Column atau str Kolom target untuk dihitung.

Pengembalian Barang

pyspark.sql.Column: semua kunci objek JSON terluar.

Examples

from pyspark.sql import functions as sf
df = spark.createDataFrame([(None,), ('{}',), ('{"key1":1, "key2":2}',)], ['data'])
df.select(sf.json_object_keys(df.data).alias('r')).collect()
[Row(r=None), Row(r=[]), Row(r=['key1', 'key2'])]