chunjun icon indicating copy to clipboard operation
chunjun copied to clipboard

[feat#1037][connector-clickhouse]override delete statement

Open berg-xu opened this issue 3 years ago • 0 comments

当实现增量实时数据Sink到Clickhouse中时,根据rowKind类型值执行相关语义操作, 而clickhouse的 DELETE 与UPDATE_BEFORE 具体实现代码为空。

因此当执行数据更新操作时,将update拆分成update_before 和update_after,对于update_before则采用delete,update_after则采用insert。

Which issue you fix

issue 1037

berg-xu avatar Aug 01 '22 07:08 berg-xu