json_object_keys

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

Sintaxe

from pyspark.sql import functions as sf

sf.json_object_keys(col)

Parâmetros

Devoluções

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

Examples

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