在pyspark中从现有数据框创建多个数据框

from pyspark.sql import SparkSession

# 创建SparkSession对象
spark = SparkSession.builder.getOrCreate()

# 从CSV文件创建数据框
df_csv = spark.read.csv("path/to/csv/file.csv", header=True, inferSchema=True)

# 从JSON文件创建数据框
df_json = spark.read.json("path/to/json/file.json")

# 从数据库表创建数据框
df_db = spark.read.format("jdbc").option("url", "jdbc:mysql://localhost:3306/db_name").option("dbtable", "table_name").option("user", "username").option("password", "password").load()

# 选择特定的列
df_selected = df_csv.select("column1", "column2")

# 过滤数据
df_filtered = df_csv.filter(df_csv["column1"] > 10)

# 按列进行分组并计算平均值
df_grouped = df_csv.groupBy("column1").avg("column2")

# 将数据框保存为CSV文件
df_csv.write.csv("path/to/save/csv/file.csv")

# 将数据框保存为JSON文件
df_json.write.json("path/to/save/json/file.json")

# 将数据框保存到数据库表
df_db.write.format("jdbc").option("url", "jdbc:mysql://localhost:3306/db_name").option("dbtable", "table_name").option("user", "username").option("password", "password").save()