可進(jìn)入我的博客查看原文。 Raft 算法是可以用來替代 Paxos 算法的分布式一致性算法，而且 raft 算法比 Paxos 算法更易懂且更容...
投稿
收錄了17篇文章 · 30人關(guān)注
-
分布式一致性算法：Raft 算法（Raft 論文翻譯） -
在Apache Flink中Savepoints和CheckPoints的三點不同(譯文)翻譯自：3 differences between Savepoints and Checkpoints in Apache Flink本文發(fā)布...
-
Kafka史上最詳細(xì)原理總結(jié)上
Kafka史上最詳細(xì)原理總結(jié)分為上下兩部分，承上啟下 Kafka史上最詳細(xì)原理總結(jié)上 Kafka史上最詳細(xì)原理總結(jié)下 Kafka Kafka是最...
-
Flink Table API 和SQL的流處理Flink 的 Table API 和SQL支持是用于批處理和流處理的統(tǒng)一API。這意味著 Table API 和SQL查詢具有相同的語義，無論...
-
Flink 指標(biāo)（二）
報告（Reporter） 通過 conf/flink-conf.yaml 文件配置一個或多個 Reporters 來暴露度量值給外部系統(tǒng)，這些 ...
-
Flink 指標(biāo)（一）
Flink 自帶一個度量系統(tǒng)，允許收集和公開指標(biāo)到外部系統(tǒng)。 注冊指標(biāo) 可以通過繼承 RichFunction，在繼承類里面調(diào)用 getRunt...
-
Flink Table API 和 SQL
Apache Flink 具有兩個關(guān)系型API：Table API 和SQL，用于統(tǒng)一流和批處理。Table API 是用于 Scala 和 J...
-
Flink DataSet API
Data Source Data Source 創(chuàng)建初始數(shù)據(jù)集。Flink 附帶了幾種內(nèi)置輸入格式，可以從通用文件格式創(chuàng)建數(shù)據(jù)集。Executi...
-
Flink DataStream API
Data Sources 源是程序讀取輸入數(shù)據(jù)的位置?？梢允褂?StreamExecutionEnvironment.addSource(sou...
-
Flink DataStream Side Output
Side Output 功能從 Flink 1.3.0 版本開始提供，F(xiàn)LINK-4460 除了從 DataStream 操作的結(jié)果中獲取主數(shù)據(jù)...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1708946/flink_squirrel.png', '推薦專題《Flink專題》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/8b289aa69912?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}