Flink SQL在线调试功能能够帮助用户数据探索与逻辑校验,调试功能要求如下: 为了满足上述要求,我们开发了基于redis的调试插件,用该插件...
Flink SQL经常需要关联维表,使用redis作为维表存储介质能获得较快的响应速度,大多情况维表有多个字段,写入与维表查询时只能使用conc...
开发思路 运行环境全面升级到jdk11后,原基于hive catalog的flink catlog不能再使用,原因是现在hive所有版本都不支持...
插件名称:flink-connector-redis 插件地址:https://github.com/jeff-zou/flink-connec...
引子: mybatis这类ORM在往数据库insert对象后,会顺带将数据库中的自增主键值赋值给对象的id,这个功能给我们的开发带来了很多方便,...
Caffeine使用一个ConcurrencyHashMap来保存所有数据,那它的过期淘汰策略采用的什么的方式与数据结构呢?其中写过期是使用wr...
插件名称:flink-connector-redis 插件地址:https://github.com/jeff-zou/flink-connec...
协程本质: go协程本质上还是用线程来运行代码,只是在多线程上增加了调度器,通过调度器让每一个线程可以执行多个协程。 实现原理: go协程使用G...
在实时计算平台接入业务过程中,经常遇到这样一个问题: 第一个任务获得的最新状态需要提供给后续一个或者多个任务使用。解决这个问题有很多方法,将状态...