我得到了一个在mysql中定义的推荐表，它有3列：user_id，item_id，rank，flink会在用户点击某个项目时计算一些推荐并将结果插入mysql，我只想让mysql存储用户最新点击触发的推荐。既然flink mysql连接器不支持删除，我该如何实现呢？如果需要大数据计算，这种框架在此类场景中常用吗？
r1wp621o1#
Flink的MySQL连接器支持删除[1]。您必须定义一个主键，然后它将执行UPDATE/DELETES。如果您不提供主键，连接器将以append模式运行。[1][https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/)
1条答案
按热度按时间r1wp621o1#
Flink的MySQL连接器支持删除[1]。您必须定义一个主键，然后它将执行UPDATE/DELETES。如果您不提供主键，连接器将以append模式运行。
[1][https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/)