Função com valor de tabela.json_tuple

Cria uma nova linha para uma coluna JSON de acordo com os nomes de campo fornecidos.

Sintaxe

Python

spark.tvf.json_tuple(input, *fields)

Parâmetros

Parâmetro	Tipo	Descrição
input	pyspark.sql.Column	coluna de strings em formato JSON
fields	pyspark.sql.Column	Um campo ou campos para extrair

Parâmetro	Tipo	Descrição
input	pyspark.sql.Column	coluna de strings em formato JSON
fields	pyspark.sql.Column	Um campo ou campos para extrair

Devoluções

pyspark.sql.DataFrameUm DataFrame com os valores dos campos extraídos.

Exemplos

Python

import pyspark.sql.functions as sf
spark.tvf.json_tuple(
    sf.lit('{"f1": "value1", "f2": "value2"}'), sf.lit("f1"), sf.lit("f2")
).show()

Output

+------+------+
|    c0|    c1|
+------+------+
|value1|value2|
+------+------+