spark字符串转json

在Spark中，可以使用`spark.read.json()`方法将字符串转换为JSON格式。示例代码如下：

from pyspark.sql import SparkSession

spark = SparkSession.builder.appName("StringToJson").getOrCreate()

# 定义字符串
json_string = '{"name": "Alice", "age": 25, "city": "New York"}'

# 将字符串转换为DataFrame
df = spark.read.json(sc.parallelize([json_string]))

# 显示DataFrame
df.show()

输出结果为：

+---+-------+--------+
|age|   city|    name|
+---+-------+--------+
| 25|New York|   Alice|
+---+-------+--------+