pyspark.sql.tvf.TableValuedFunction.json_tuple#

TableValuedFunction.json_tuple(input, *fields)[source]#

Creates a new row for a json column according to the given field names.

New in version 4.0.0.

Parameters

inputColumn

string column in json format

fieldsColumn

a field or fields to extract

Returns

DataFrame

See also

pyspark.sql.functions.json_tuple()

Examples

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