chunjun
chunjun copied to clipboard
[feat#1037][connector-clickhouse]override delete statement
当实现增量实时数据Sink到Clickhouse中时,根据rowKind类型值执行相关语义操作, 而clickhouse的 DELETE 与UPDATE_BEFORE 具体实现代码为空。
因此当执行数据更新操作时,将update拆分成update_before 和update_after,对于update_before则采用delete,update_after则采用insert。