TableValuedFunction.json_demet

Verilen alan adlarına göre bir json sütunu için yeni bir satır oluşturur.

Sözdizimi

spark.tvf.json_tuple(input, *fields)

Parametreler

Parametre	Türü	Description
input	pyspark.sql.Column	Json biçiminde dize sütunu
fields	pyspark.sql.Column	Ayıklanması gereken alan veya alanlar

İade

pyspark.sql.DataFrame: Ayıklanan alan değerlerine sahip bir DataFrame.

Örnekler

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

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