大家好!
可爱的flink贡献者,能不能增加个JDBC Sink
更新策略接口?目前只有增量插入,实际中对更新需求还是非常普遍的,目前要想支持更新,只能自己修改源码增加,这样感觉不是很友好。棒棒的贡献者,期待JDBC
Sink 更新策略接口的出现。
基于flink工作的伙伴们,如果有谁实现了JDBC Sink 更新策略接口,希望能分享下代码,感谢!
[email protected]
大家好!
可爱的flink贡献者,能不能增加个JDBC Sink
更新策略接口?目前只有增量插入,实际中对更新需求还是非常普遍的,目前要想支持更新,只能自己修改源码增加,这样感觉不是很友好。棒棒的贡献者,期待JDBC
Sink 更新策略接口的出现。
基于flink工作的伙伴们,如果有谁实现了JDBC Sink 更新策略接口,希望能分享下代码,感谢!
[email protected]