240 发简信
IP属地:广东
  • Flink SQL在线调试功能的实现

    Flink SQL在线调试功能能够帮助用户数据探索与逻辑校验,调试功能要求如下: 为了满足上述要求,我们开发了基于redis的调试插件,用该插件...

  • Flink SQL多字段的维表关联查询-flink-connector-redis

    Flink SQL经常需要关联维表,使用redis作为维表存储介质能获得较快的响应速度,大多情况维表有多个字段,写入与维表查询时只能使用conc...

  • flink catalog 之 flink-catalog-in-jdbc

    开发思路 运行环境全面升级到jdk11后,原基于hive catalog的flink catlog不能再使用,原因是现在hive所有版本都不支持...

  • flink维表查询redis之flink-connector-redis

    插件名称:flink-connector-redis 插件地址:https://github.com/jeff-zou/flink-connec...

  • Resize,w 360,h 240
    mybatis insert后返回主键ID实现原理及源码分析

    引子: mybatis这类ORM在往数据库insert对象后,会顺带将数据库中的自增主键值赋值给对象的id,这个功能给我们的开发带来了很多方便,...

  • W-TinyLFU源码分析(Caffeine)

    Caffeine使用一个ConcurrencyHashMap来保存所有数据,那它的过期淘汰策略采用的什么的方式与数据结构呢?其中写过期是使用wr...

  • flink1.12 sql向redis实时写数据

    插件名称:flink-connector-redis 插件地址:https://github.com/jeff-zou/flink-connec...

  • Resize,w 360,h 240
    go协程学习笔记

    协程本质: go协程本质上还是用线程来运行代码,只是在多线程上增加了调度器,通过调度器让每一个线程可以执行多个协程。 实现原理: go协程使用G...

  • FLINK基于SQL向redis更新多维度状态(多字段)

    在实时计算平台接入业务过程中,经常遇到这样一个问题: 第一个任务获得的最新状态需要提供给后续一个或者多个任务使用。解决这个问题有很多方法,将状态...