Pular para o conteúdo principal

comprimento_da_matriz_json

Retorna o número de elementos no array JSON mais externo. NULL é retornado caso haja qualquer outra string JSON válida, NULL caso haja um JSON inválido.

Sintaxe

Python
from pyspark.sql import functions as sf

sf.json_array_length(col)

Parâmetros

Parâmetro

Tipo

Descrição

col

pyspark.sql.Column ou str

coluna de destino para compute .

Devoluções

pyspark.sql.Column: comprimento do array JSON.

Exemplos

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