Condividi tramite


json_object_keys

Restituisce tutte le chiavi dell'oggetto JSON più esterno come matrice. Se viene specificato un oggetto JSON valido, tutte le chiavi dell'oggetto più esterno verranno restituite come matrice. Se si tratta di un'altra stringa JSON valida, una stringa JSON non valida o una stringa vuota, la funzione restituisce Null.

Sintassi

from pyspark.sql import functions as sf

sf.json_object_keys(col)

Parametri

Parametro TIPO Description
col pyspark.sql.Column o str Colonna di destinazione su cui eseguire il calcolo.

Restituzioni

pyspark.sql.Column: tutte le chiavi dell'oggetto JSON più esterno.

Esempi

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