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