發(fā)簡信
IP屬地：香港
-
Flink源碼閱讀（三）--- ExecutionGraph 的生成
本文內(nèi)容是基于Flink 1.9來講解。在執(zhí)行Flink任務(wù)的時候，會涉及到三個Graph，分別是StreamGraph，JobGraph，ExecutionGraph。其中...
-
Flink 源碼之Credit Based反壓
Flink源碼分析系列文檔目錄 請點擊：Flink 源碼分析系列文檔目錄[http://www.itdecent.cn/p/d4a372809e3d] 什么是credit反...
-
如果是磁盤文件，b+Tree 會比 skiplist 好很多。磁盤查詢性能比內(nèi)存差很多，所以盡量減少查詢的次數(shù)。
b+ tree 每個節(jié)點有好多數(shù)據(jù)，每次查詢可以查詢一批數(shù)據(jù)到內(nèi)存中。b+ 樹的層數(shù)低，可以減少訪問磁盤的次數(shù)。Skip List--跳表（全網(wǎng)最詳細的跳表文章沒有之一）
跳表是一種神奇的數(shù)據(jù)結(jié)構(gòu)，因為幾乎所有版本的大學本科教材上都沒有跳表這種數(shù)據(jù)結(jié)構(gòu)，而且神書《算法導論》、《算法第四版》這兩本書中也沒有介紹跳表。但是跳表插入、刪除、查找元素的...
-
RocksDB 的設(shè)計依賴于 LSM Tree 的思想，LSM Tree 的特性就是生成的 sst 都是不可變的問題件，所以可以保證文件不被修改。
RocksDB系列十二：Checkpoints
??Checkpoint是RocksDB的一個feature，主要支持對當前正在運行的數(shù)據(jù)庫制作一個snapshot。Checkpoints是一個時間點上的snapshot。...
-
簡析Flink狀態(tài)生存時間（State TTL）機制的底層實現(xiàn)前言 很久沒寫過源碼走讀類型的文章了。最近在做業(yè)務(wù)需求時用Flink的State TTL非常多，今天就來探索一下吧。 從Flink 1.6版本開始，社區(qū)為狀態(tài)引入了TTL（t...
-
本地Gitbook安裝和使用（windows下）一、快速開始 安裝Nodejs教程：http://www.itdecent.cn/p/cc26e5d0f10f 安裝gitbook npm install gitbook-...
-
Flink Redis Sink用法與支持過期時間的改進
Flink默認提供了很多開箱即用的連接器，比如與Kafka、RabbitMQ、HDFS、ElasticSearch等對接的連接器。還有一些不那么常用的連接器則由Apache ...
-
用兩階段聚合法解決Flink keyBy()算子傾斜這是上周出現(xiàn)的問題了，簡單做個記錄。 有一個按平臺類型實時統(tǒng)計用戶活躍的程序，代碼框架如下。 就是水印→開窗→聚合→輸出的經(jīng)典套路。程序正常運行一段時間之后，連續(xù)報檢查點超時...
