想问一下在PyFlink环境的问题[阿里云实时计算 Flink版] 暂停朗读为您朗读

求助大家，以下试验在PyFlink环境。 在StreamTableEnvironment下以SQL语句创建source表和sink表，计划将上游MySQL表同步到下游MySQL表，目前测试增删改都已同步成功。 那么，在insert到sink之前可以针对不同操作类型（insert、update、delete）分别处理吗？ 比如不想delete下游数据，只给对应行增加已删除标签。