最近在项目中用到了flink异步io模式去查询redis，相比于之前的同步访问模式，性能提升了好几倍，感叹异步io模式的强大，趁着这段时间有空好...

flink写入kafka默认采用的分区策略的代码实现在FlinkFixedPartitioner这个类中，并不是我们理解的轮盘转方式写入下游分区...

rocksdb相对于mysql等数据库来说，比较小众，即使接触过一段时间flink后，还是会很好奇flink为啥要选择rocksdb来做状态存储...

flink的窗口时间属性TimeCharacteristic分为三种：ProcessingTime，IngestionTime，EventTim...

flink中的ProcessWindowFunction经常用在窗口触发后对结果的数据的迭代处理以及获得窗口的开始时间和截止时间等操作。它可以结...

flink为了提高执行效率，会将部分算子进行合并，合并后组成operator chain,这样整个operator chain作为一个JobVe...

在flink中我们经常会用到ReduceFunction来合并两个参数生成一个新的值，这个新的值同时也可以再下一次reduce操作中跟新的参数的...

在flink的ProcessFunction中，我们可以注册定时器设定延迟多长时间后执行某类操作，例如像这种：context.timerServ...