请我如何可以应用CDC（变更数据捕获），我用Spark读取的数据库，然后将其保存为 parquet 到HADOOP HDFS.这是代码：

spark = SparkSession \
        .builder \
        .appName("Ingest") \
        .master("local[*]") \
        .config("spark.driver.extraClassPath", "/home.../mysql-connector-java-5.1.30.jar") \
        .getOrCreate()
df = spark.read\
        .format("jdbc") \
        .option("url", "jdbc:mysql://localhost:3306/classicmodels") \
        .option("driver", "com.mysql.jdbc.Driver") \
        .option("dbtable", "employees") \
        .option("user", "...") \
        .option("password", "...").load()
print(df.show())
dataframe_mysql.write.parquet("hdfs://localhost:9000/...")

代码返回在 Dataframe 中读取的数据。