答复: Flink Datastream实现删除操作

您好， Iceberg 为 Flink 实现的 connector 同时支持 DataStream API 和 Table API[1]。其 DataStream API 提供 Append（默认行为）、Overwrite、Upsert 三种可选的模式，您可以使用下面的 Java 代码片段实现： 首先创建对应数据行 Schema 格式的反序列化器，例如，可以使用 RowDataDebeziumDeserializeSchema 的生成器来快速构造一个： private RowDataDebeziumDeserializeSchema getDeserializer(

Flink Datastream实现删除操作

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