如何使用结构化流的writestream进行重新分区的文件写入？

from pyspark.sql import SparkSession
from pyspark.sql.functions import col

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

source_df = spark.read.format("csv").option("header", "true").load("source_file.csv")
repartitioned_df = source_df.repartition("partition_column")

repartitioned_df.writeStream.format("csv").option("header", "true").option("path", "target_directory").start()