pyspark:如何填充列中的值并替换为另一个带条件的dataframe中的列

from pyspark.sql import SparkSession

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

# 创建要填充的DataFrame
data1 = [("A", 1), ("B", 2), ("C", None)]
df1 = spark.createDataFrame(data1, ["col1", "col2"])

# 创建带条件的DataFrame
data2 = [("A", 10), ("B", 20)]
df2 = spark.createDataFrame(data2, ["col1", "col3"])

# 使用join方法连接两个DataFrame
joined_df = df1.join(df2, on="col1", how="left")

# 使用withColumn方法填充列并替换为另一个DataFrame中的列
filled_df = joined_df.withColumn("col2", joined_df["col3"])

# 显示结果
filled_df.show()