會以陣列形式回傳最外層 JSON 物件的所有鍵。 如果給出有效的 JSON 物件,最外層物件的所有鍵值會以陣列形式回傳。 如果是其他有效的 JSON 字串、無效的 JSON 字串或空字串,函式會回傳 null。
語法
from pyspark.sql import functions as sf
sf.json_object_keys(col)
參數
| 參數 | 類型 | Description |
|---|---|---|
col |
pyspark.sql.Column 或 str |
計算目標欄位。 |
退貨
pyspark.sql.Column:最外層 JSON 物件的所有鍵。
範例
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'])]