INFO-实时传输写入iceberg实现逻辑删除

适用模块

数据传输

具体说明
用户有以下场景:源端删除一条记录后,目标端只记录删除的标记,而不执行物理删除,实现记录级别的逻辑删除(打标记)。
使用示例
可设置任务参数
target.delete.to.insert=true
会将Delete转insert,但并没有标识出这一行原本是否是插入或删除,因此要求目标iceberg表,至少需要一个字段记录 op_type

作者:楚展航