json_object_keys

Renvoie toutes les clés de l'objet JSON le plus externe sous forme de tableau. Si un objet JSON valide est fourni, toutes les clés de l'objet le plus externe seront renvoyées sous forme de tableau. S'il s'agit d'une autre chaîne JSON valide, d'une chaîne JSON non valide ou d'une chaîne vide, la fonction renvoie la valeur null.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.json_object_keys(col)

parameter

parameter	Type	Description
col	pyspark.sql.Column ou str	Colonne cible sur laquelle effectuer le calcul.

parameter	Type	Description
col	pyspark.sql.Column ou str	Colonne cible sur laquelle effectuer le calcul.

Renvoie

pyspark.sql.Column: toutes les clés de l'objet JSON le plus externe.

Exemples

Python

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()

Output

[Row(r=None), Row(r=[]), Row(r=['key1', 'key2'])]