json_object_keys

Devuelve todas las claves del objeto JSON más externo como una matriz. Si se proporciona un objeto JSON válido, todas las claves del objeto más externo se devolverán como una matriz. Si es cualquier otra cadena JSON válida, una cadena JSON no válida o una cadena vacía, la función devuelve null.

Syntax

from pyspark.sql import functions as sf

sf.json_object_keys(col)

Parámetros

Devoluciones

pyspark.sql.Column: todas las claves del objeto JSON más 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'])]