mysqlDF.write.format("org.apache.hudi") .options(Map( TABLE_TYPE_OPT_KEY -> "MERGE_ON_READ", RECORDKEY_FIELD_OPT_KEY -> "id", PRECOMBINE_FIELD_OPT_KEY -> "timestamp", PARTITIONPATH_FIELD_OPT_KEY -> "date", KEYGENERATOR_CLASS_OPT_KEY -> "org.apache.hudi.keygen.NonpartitionedKeyGenerator", HIVE_SYNC_ENABLED_OPT_KEY -> "true", HIVE_DATABASE_OPT_KEY -> "default", HIVE_TABLE_OPT_KEY -> "hudi_table", HIVE_PARTITION_FIELDS_OPT_KEY -> "date", HIVE_PARTITION_EXTRACTOR_CLASS_OPT_KEY -> "org.apache.hudi.hive.NonPartitionedExtractor", HIVE_STYLE_PARTITIONING_OPT_KEY -> "true", HIVE_ASSUME_DATE_PARTITION_OPT_KEY -> "false" )) .mode("append") .save("/path/to/hudi_table")每一句加上注释

// 将 DataFrame 中的数据写入到 Hudi 表中
mysqlDF.write.format("org.apache.hudi")
  .options(Map(
    TABLE_TYPE_OPT_KEY -> "MERGE_ON_READ", // Hudi 表的类型，这里是“MERGE_ON_READ”
    RECORDKEY_FIELD_OPT_KEY -> "id", // 记录键，这里是“id”
    PRECOMBINE_FIELD_OPT_KEY -> "timestamp", // 预合并字段，这里是“timestamp”
    PARTITIONPATH_FIELD_OPT_KEY -> "date", // 分区路径键，这里是“date”
    KEYGENERATOR_CLASS_OPT_KEY -> "org.apache.hudi.keygen.NonpartitionedKeyGenerator", // 键生成器的类，这里是“org.apache.hudi.keygen.NonpartitionedKeyGenerator”
    HIVE_SYNC_ENABLED_OPT_KEY -> "true", // 是否启用 Hive 元数据同步，这里是“true”
    HIVE_DATABASE_OPT_KEY -> "default", // Hive 数据库的名称，这里是“default”
    HIVE_TABLE_OPT_KEY -> "hudi_table", // Hive 表的名称，这里是“hudi_table”
    HIVE_PARTITION_FIELDS_OPT_KEY -> "date", // Hive 分区字段，这里是“date”
    HIVE_PARTITION_EXTRACTOR_CLASS_OPT_KEY -> "org.apache.hudi.hive.NonPartitionedExtractor", // Hive 分区提取器的类，这里是“org.apache.hudi.hive.NonPartitionedExtractor”
    HIVE_STYLE_PARTITIONING_OPT_KEY -> "true", // 是否启用 Hive 样式的分区，这里是“true”
    HIVE_ASSUME_DATE_PARTITION_OPT_KEY -> "false" // 是否启用日期分区，这里是“false”
  ))
  .mode("append") // 写入模式，这里是“append”，即添加新数据
  .save("/path/to/hudi_table") // 保存路径，这里是 Hudi 表的路径