dwd_ap_supplier_fee_detail_monthly_df.write
.mode("overwrite")
.format("doris")
.option("doris.table.identifier", "dw_dwd.dwd_ap_supplier_monthly")
.option("doris.fenodes", "xxxx:8030")
.option("doris.query.port",9030)
.option("user", "xxxxx")
.option("password", "xxxxxx")
.option("doris.batch.size",1024 * 10)
.option("doris.sink.enable-2pc","true")
.option("doris.write.fields","orderno,busimonth,billno,billtype,busi_maincateg_name")
.save()
在hive中busimonth作为分区字段放在最后,同时插入doris时,指定了字段顺序,查看结果乱序