次の方法で共有

json_object_keys

最も外側の 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'])]
  • Last updated on