Flink Datastream实现删除操作

[zapjone]

各位大佬好：
    想请教下，在使用mysql-cdc到iceberg，通过sql方式可以实现自动更新和删除功能。但在使用datastream 
api进行处理后，注册成临时表，怎么实现类似于sql方式的自动更新和删除呢？