在研究 Flink？
Flink源碼閱讀（四）--- checkpoint制作本文內(nèi)容是基于Flink 1.9來講解。Flink使用checkpoint檢查點(diǎn)來保證Exactly-Once語義的，這篇文章會(huì)從源碼角度分析下checkpoint怎么觸發(fā)的...
發(fā)簡信
IP屬地：甘肅
-
-
Gson & FastJson 序列化
顯示序列化空值 當(dāng)對象含有空值 默認(rèn)情況下對象轉(zhuǎn)json字符串： 序列化會(huì)過濾掉null值，如果要顯示空值需要對序列化特征進(jìn)行設(shè)置。 替換序列化字段名 有一個(gè)對象 測試
-
-
分布式Snapshot和Flink Checkpointing簡介
摘要：最近在學(xué)習(xí)Flink的Fault Tolerance，了解到Flink在Chandy Lamport Algorithm的基礎(chǔ)上擴(kuò)展實(shí)現(xiàn)了一套分布式Checkpoint...
-
情景l(fā)inux--shell如何實(shí)現(xiàn)多線程？
情景 shell腳本的執(zhí)行效率雖高，但當(dāng)任務(wù)量巨大時(shí)仍然需要較長的時(shí)間，尤其是需要執(zhí)行一大批的命令時(shí)。因?yàn)槟J(rèn)情況下，shell腳本中的命令是串行執(zhí)行的。如果這些命令相互之間...
-
如何在Calcite中注冊函數(shù)
很多同學(xué)在使用Calcite的過程中需要自定義函數(shù)， 現(xiàn)在講講如何定自義函數(shù) 1. Calcite 內(nèi)置函數(shù)和對應(yīng)的流程 Calcite中內(nèi)置的函數(shù)主要在SqlStdOper...
-
-
已經(jīng)修改，多謝指正
關(guān)系代數(shù)基礎(chǔ)
本章主要來自《數(shù)據(jù)庫系統(tǒng)概論》第六章的內(nèi)容，主要介紹關(guān)系代數(shù)相關(guān)的知識(shí)，其實(shí)大家也可以參考這篇文章 SQL 形式化語言——關(guān)系代數(shù)。 關(guān)系代數(shù)是一種過程化查詢語言，它包括一個(gè)...
-
04 Lambda 和 Kappa 架構(gòu)
這篇總結(jié)來自極客時(shí)間專欄《大規(guī)模數(shù)據(jù)處理實(shí)踐》的 10-11 節(jié)。 關(guān)于第八節(jié) CAP 的內(nèi)容可以參考之前總結(jié)的另一篇文章 分布式系統(tǒng)的一致性協(xié)議之 2PC 和 3PC，這里...
