Udostępnij przez


json_object_keys

Zwraca wszystkie klucze najbardziej zewnętrznego obiektu JSON jako tablicę. Jeśli zostanie podany prawidłowy obiekt JSON, wszystkie klucze obiektu najbardziej zewnętrznego zostaną zwrócone jako tablica. Jeśli jest to jakikolwiek inny prawidłowy ciąg JSON, nieprawidłowy ciąg JSON lub pusty ciąg, funkcja zwraca wartość null.

Składnia

from pyspark.sql import functions as sf

sf.json_object_keys(col)

Parametry

Parameter Typ Description
col pyspark.sql.Column lub str Kolumna docelowa do obliczenia.

Zwraca

pyspark.sql.Column: wszystkie klucze najbardziej zewnętrznego obiektu JSON.

Przykłady

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'])]