flink处理数据流


0

数据格式: {"time": "2022-01-01 00:00:00", properties: {"a": 1, "b": 1, ...}}
properties 里边的key不固定,也不知道都有什么

mysql 有一个专门存属性的表
CREATE TABLE properties_test (
id int NOT NULL AUTO_INCREMENT COMMENT '主键id',
property_name varchar(50) COMMENT '属性名',
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;

flink 收到数据 遍历properties, 查找 mysql表properties_test里边有没有这个属性(这个不要总查mysql,最好有一个地方能缓存),如果没有 insert一条数据

这个改怎么实现

0 答案


我来回答

写文章

提问题

面试题