Flink SQL在线调试功能能够帮助用户数据探索与逻辑校验，调试功能要求如下： 为了满足上述要求，我们开发了基于redis的调试插件，用该插件替换原sink目标，具体步骤如...
发简信
IP属地：广东
-
Flink SQL在线调试功能的实现
-
Flink SQL多字段的维表关联查询-flink-connector-redis
Flink SQL经常需要关联维表，使用redis作为维表存储介质能获得较快的响应速度，大多情况维表有多个字段,写入与维表查询时只能使用concat与table functi...
-
flink catalog 之 flink-catalog-in-jdbc
开发思路 运行环境全面升级到jdk11后，原基于hive catalog的flink catlog不能再使用，原因是现在hive所有版本都不支持jdk11,但在大趋势下jdk...
-
flink维表查询redis之flink-connector-redis
插件名称：flink-connector-redis 插件地址：https://github.com/jeff-zou/flink-connector-redis.git[h...
-
本博客所有内容均适用知识共享-署名-相同方式共享（CC-BY-SA）4.0协议。
-
mybatis insert后返回主键ID实现原理及源码分析
引子： mybatis这类ORM在往数据库insert对象后，会顺带将数据库中的自增主键值赋值给对象的id,这个功能给我们的开发带来了很多方便，那它是怎么实现的呢? 源码分析...
-
W-TinyLFU源码分析（Caffeine）
Caffeine使用一个ConcurrencyHashMap来保存所有数据，那它的过期淘汰策略采用的什么的方式与数据结构呢?其中写过期是使用writeOrderDeque,这...
-
flink1.12 sql向redis实时写数据
插件名称：flink-connector-redis 插件地址：https://github.com/jeff-zou/flink-connector-redis.git[h...
-
Java NIO——零拷贝什么是零拷贝 WIKI中对其有如下定义： "Zero-copy" describes computer operations in which the CPU does no...
-
从图上来看，sendfile不应该是两次上下切换么？
Java NIO——零拷贝
什么是零拷贝 WIKI中对其有如下定义： "Zero-copy" describes computer operations in which the CPU does no...
-
如果对CA机构发起中间人攻击，让浏览器里的CA机构公钥是假的，这个有可能吗?
为什么 HTTPS 是安全的？你知道吗？
都知道 HTTPS 安全，可是为什么安全呢？看小电影还是浏览正常网站，一定要检查是不是 HTTPS 的，HTTP有可能被中间人攻击和拦截，下面就是详细的 HTTPS 原理，帮...
-
-
FLINK基于SQL向redis更新多维度状态（多字段）
在实时计算平台接入业务过程中，经常遇到这样一个问题： 第一个任务获得的最新状态需要提供给后续一个或者多个任务使用。解决这个问题有很多方法，将状态序列化到消息队列中或者持久化到...
-
log4j日志落地文件改造-方便以文件形式进行日志文件同步
log4j日志落地文件是先写入到文件名为*.log的文件中，达到一定条件后重命名，再生成一个新的空*.log文件，这种方式有一个弊端就是最新日志内容始终在*.log中，很不利...
-
centos7.4/7.5搭建kafka1.1.0消息队列集群(使用SASL_PLAINTEXT)
kafka增加了账号认证后标志着它向企业级发展迈出了关键的一步，在这个功能后kafka也终于有了大版本，到现在已经演进到1.1.0，发展迅速以至于国内相关实践的资料很少，或者...
