TableValuedFunction.json_tuple.

Crée une nouvelle ligne pour une colonne JSON en fonction des noms de champs donnés.

Syntaxe

Python

spark.tvf.json_tuple(input, *fields)

parameter

parameter	Type	Description
input	pyspark.sql.Column	Colonne de chaîne au format JSON
fields	pyspark.sql.Column	Un ou plusieurs champs à extraire

parameter	Type	Description
input	pyspark.sql.Column	Colonne de chaîne au format JSON
fields	pyspark.sql.Column	Un ou plusieurs champs à extraire

Renvoie

pyspark.sql.DataFrame : un DataFrame avec des valeurs de champ extraites.

Exemples

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|
+------+------+