json_object_keys

Retorna todas as chaves do objeto JSON mais externo como um array. Se um objeto JSON válido for fornecido, todas as chaves do objeto mais externo serão retornadas como uma matriz. Se a string recebida for qualquer outra string JSON válida, uma string JSON inválida ou uma string vazia, a função retorna nulo.

Sintaxe

Python

from pyspark.sql import functions as sf

sf.json_object_keys(col)

Parâmetros

Parâmetro	Tipo	Descrição
col	pyspark.sql.Column ou str	coluna de destino para compute .

Devoluções

pyspark.sql.Column: todas as chaves do objeto JSON mais externo.

Exemplos

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