json_array_length

Renvoie le nombre d'éléments dans le tableau JSON le plus externe. NULL est renvoyé en cas de toute autre chaîne JSON valide, NULL ou un JSON invalide.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.json_array_length(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: longueur du tableau JSON.

Exemples

Python

from pyspark.sql import functions as sf
df = spark.createDataFrame([(None,), ('[1, 2, 3]',), ('[]',)], ['data'])
df.select(sf.json_array_length(df.data).alias('r')).collect()

Output

[Row(r=None), Row(r=3), Row(r=0)]