Java8特性大全（最新版）
- 2022 年 2 月 13 日
- 筆記
一、序言 Java8 是一个里程碑式的版本，凭借如下新特性，让人对其赞不绝口。 Lambda 表达式给代码构建带来了全新 …
Continue Reading
Flink 如何通过2PC实现Exactly-once语义 （源码分析）
- 2022 年 1 月 26 日
- 筆記
Flink通过全局快照能保证内部处理的Exactly-once语义 但是端到端的Exactly-once还需要下游数据源 …
Continue Reading
Flink 非对齐Unaligned的checkpoint（源码分析）
- 2022 年 1 月 12 日
- 筆記
本文源码基于flink1.14 在帮助用户排查任务的时候，经常会发现部分task处理的慢，在Exactly once语义 …
Continue Reading
Flink sql 之 两阶段聚合与 TwoStageOptimizedAggregateRule（源码分析）
- 2022 年 1 月 6 日
- 筆記
本文源码基于flink1.14 上一篇文章分析了《flink的minibatch微批处理》的源码 乘热打铁分析一下两阶段 …
Continue Reading
Flink sql 之AsyncIO与LookupJoin的几个疑问 （源码分析）
- 2021 年 11 月 11 日
- 筆記
本文源码基于flink 1.14 被同事问到几个关于AsyncIO和lookUp维表的问题所以翻了下源码，从源码的角度解 …
Continue Reading
Flink sql 之 join 与 StreamPhysicalJoinRule （源码解析）
- 2021 年 10 月 26 日
- 筆記
源码分析基于flink1.14 Join是flink中最常用的操作之一，但是如果滥用的话会有很多的性能问题，了解一下Fl …
Continue Reading
Flink sql 之 TopN 与 StreamPhysicalRankRule (源码解析)
- 2021 年 10 月 20 日
- 筆記
基于flink1.14的源码做解析 公司内有很多业务方都在使用我们Flink sql平台做TopN的计算，今天同事突然问 …
Continue Reading
Flink Sql 之 Calcite Volcano优化器（源码解析）
- 2021 年 10 月 19 日
- 筆記
Calcite作为大数据领域最常用的SQL解析引擎，支持Flink , hive, kylin , druid等大型项 …
Continue Reading
Apache Pulsar 在能源互联网领域的落地实践
- 2021 年 3 月 16 日
- 筆記
关于 Apache Pulsar Apache Pulsar 是 Apache 软件基金会顶级项目，是下一代云原生分布式 …
Continue Reading
再也不担心写出臃肿的Flink流处理程序啦，发现一款将Flink与Spring生态完美融合的脚手架工程-懒松鼠Flink-Boot
- 2020 年 12 月 4 日
- 筆記
目录 你可能面临如下苦恼： 接口缓存 重试机制 Bean校验 等等…… 它为流计算开发工程师解决 …
Continue Reading