简介 由于Spark应用写数据到Hive表时，容易因为shuffle数过多导致生成过多小文件，影响集群存储利用率；...[作者空间]

之前使用过foreach单条处理的MySQLSink，可能导致连续开关连接，性能较差，故通过prepareStat...[作者空间]

1.foreachBatchspark2.4以后可以直接使用foreachBatch调用sparksql支持的jd...[作者空间]