如何在pyspark上更改JSON结构？

# 导入必要的库
from pyspark.sql import SparkSession
from pyspark.sql.functions import col

# 创建SparkSession
spark = SparkSession.builder.appName("JSON Transformation").getOrCreate()

# 读取JSON数据
json_data = spark.read.json("path/to/json/file.json")

# 显示原始数据
json_data.show()

# 更改JSON结构
transformed_data = json_data.select(
    col("original_field").alias("new_field"),
    col("nested_field.nested_subfield").alias("new_nested_field")
)

# 显示更改后的数据
transformed_data.show()

# 将更改后的数据保存为JSON文件
transformed_data.write.json("path/to/output/file.json")