नोट
इस पेज तक पहुँच के लिए प्रमाणन की आवश्यकता होती है. आप साइन इन करने या निर्देशिकाओं को बदलने का प्रयास कर सकते हैं.
इस पेज तक पहुँच के लिए प्रमाणन की आवश्यकता होती है. आप निर्देशिकाओं को बदलने का प्रयास कर सकते हैं.
Creates a new row for a json column according to the given field names.
Syntax
spark.tvf.json_tuple(input, *fields)
Parameters
| Parameter | Type | Description |
|---|---|---|
input |
pyspark.sql.Column |
String column in json format |
fields |
pyspark.sql.Column |
A field or fields to extract |
Returns
pyspark.sql.DataFrame: A DataFrame with extracted field values.
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|
+------+------+