在研究 Flink？
Flink源码阅读（四）--- checkpoint制作本文内容是基于Flink 1.9来讲解。Flink使用checkpoint检查点来保证Exactly-Once语义的，这篇文章会从源码角度分析下checkpoint怎么触发的...
发简信
IP属地：山东
-
-
Gson & FastJson 序列化
显示序列化空值 当对象含有空值 默认情况下对象转json字符串： 序列化会过滤掉null值，如果要显示空值需要对序列化特征进行设置。 替换序列化字段名 有一个对象 测试
-
-
分布式Snapshot和Flink Checkpointing简介
摘要：最近在学习Flink的Fault Tolerance，了解到Flink在Chandy Lamport Algorithm的基础上扩展实现了一套分布式Checkpoint...
-
情景linux--shell如何实现多线程？
情景 shell脚本的执行效率虽高，但当任务量巨大时仍然需要较长的时间，尤其是需要执行一大批的命令时。因为默认情况下，shell脚本中的命令是串行执行的。如果这些命令相互之间...
-
如何在Calcite中注册函数
很多同学在使用Calcite的过程中需要自定义函数， 现在讲讲如何定自义函数 1. Calcite 内置函数和对应的流程 Calcite中内置的函数主要在SqlStdOper...
-
-
04 Lambda 和 Kappa 架构
这篇总结来自极客时间专栏《大规模数据处理实践》的 10-11 节。 关于第八节 CAP 的内容可以参考之前总结的另一篇文章 分布式系统的一致性协议之 2PC 和 3PC，这里...
