往hudi分区表中追加数据

您可以使用Apache Hudi提供的DeltaStreamer工具将新数据追加到Hudi分区表中。以下是一个示例命令：

java -jar hudi-deltastreamer-xxx.jar \
--props /path/to/config/file.properties \
--schemaprovider-class org.apache.hudi.utilities.schema.FilebasedSchemaProvider \
--source-class org.apache.hudi.utilities.sources.JsonKafkaSource \
--source-ordering-field timestamp \
--target-base-path /path/to/hudi/base \
--target-table my_hudi_table \
--props /path/to/hudi/properties \
--op UPSERT \
--partition-value my_partition_value

其中，需要替换以下参数：

- `/path/to/config/file.properties`：DeltaStreamer配置文件的路径。
- `org.apache.hudi.utilities.sources.JsonKafkaSource`：数据源类型，可以根据自己的情况选择。
- `timestamp`：数据源中用于保证顺序性的字段名。
- `/path/to/hudi/base`：Hudi表的根路径。
- `my_hudi_table`：Hudi表的名称。
- `/path/to/hudi/properties`：Hudi表的配置文件路径。
- `UPSERT`：操作类型，可以是INSERT、UPSERT或BULK_INSERT。
- `my_partition_value`：新数据所属的分区值。

您可以根据自己的情况进行替换和调整。