You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "baiyg25281@hundsun.com" <ba...@hundsun.com> on 2019/03/25 07:58:42 UTC
增加 JDBC Sink 更新策略接口
大家好!
可爱的flink贡献者,能不能增加个JDBC Sink 更新策略接口?目前只有增量插入,实际中对更新需求还是非常普遍的,目前要想支持更新,只能自己修改源码增加,这样感觉不是很友好。棒棒的贡献者,期待JDBC Sink 更新策略接口的出现。
基于flink工作的伙伴们,如果有谁实现了JDBC Sink 更新策略接口,希望能分享下代码,感谢!
baiyg25281@hundsun.com
Re: 增加 JDBC Sink 更新策略接口
Posted by 陈韬 <to...@qq.com>.
我的做法是,在MysqlSink中,使用replace into,然后根据数据会根据唯一键,自己考虑新增还是更新。
希望能对你有点价值吧
> 在 2019年3月25日,下午3:58,baiyg25281@hundsun.com 写道:
>
> 大家好!
>
> 可爱的flink贡献者,能不能增加个JDBC Sink 更新策略接口?目前只有增量插入,实际中对更新需求还是非常普遍的,目前要想支持更新,只能自己修改源码增加,这样感觉不是很友好。棒棒的贡献者,期待JDBC Sink 更新策略接口的出现。
>
> 基于flink工作的伙伴们,如果有谁实现了JDBC Sink 更新策略接口,希望能分享下代码,感谢!
>
>
>
> baiyg25281@hundsun.com