todd5167

背景 Flink LookupTableSource 通过使用流数据的一列或者多列的值，加载外部存储数据（维表数据），进而完成对流数据的字段扩展。在维表数据不频繁变更的情况下...

LittleMagic

前言 好久不见（鞠躬 今年以来的主要工作方向之一就是部门内流批一体能力的建设与落地。虽然这个概念早已成为老生常谈，并且笔者现在还没什么fancy的成果（惭愧），但今天还是想随...

LittleMagic

前言 为了解决Flink作业使用RocksDB状态后端时的内存超用问题，Flink早在1.10版本就实现了RocksDB的托管内存（managed memory）机制。用户只...

LittleMagic

前言 在有代表性的关系型数据库如MySQL、SQL Server、Oracle中，数据存储与索引的基本结构就是我们耳熟能详的B树和B+树。而在一些主流的NoSQL数据库如HB...

LittleMagic

前言 最近正在准备关于Flink 1.13 / 1.14版本新特性的内部分享，顺便做点记录。 又见网络缓存 很久没有聊过Flink的网络栈了，但相信大家对网络缓存（Netwo...

LittleMagic

前言 今天是大年初一，祝各位虎年大吉大利~ 近期受工作变动影响，博客又荒废了许久。今天难得有空，就前段时间内部技术分享里提到的一个小知识点来写几笔。 对象重用（object ...

LittleMagic

前言 “访问者模式”在之前的文章里已经出现过几次了，择日不如撞日，今天接着聊吧。 The Visitor Pattern 访问者模式属于GoF设计模式分类中的行为型模式。它的...

LittleMagic

前言 今天本应放一首适合高考气氛的歌的，但是既然受疫情影响推迟了，还是老老实实写点技术相关的吧。 对于实时的流式处理系统来说，我们需要关注数据输入、计算和输出的及时性，所以处...