1、DorisSink重构,重构出一个抽象类DorisAbstractSink,和一个实现类DorisGenericJsonRecordSink。
2、使用微批提交JsonArray的方式插入数据,效率从1000条5分钟到1000条1秒内。
3、ScheduledExecutorService定时flush到doris
1、DorisSink重构,重构出一个抽象类DorisAbstractSink,和一个实现类DorisGenericJsonRecordSink。
2、使用微批提交JsonArray的方式插入数据,效率从1000条5分钟到1000条1秒内。
3、ScheduledExecutorService定时flush到doris