發(fā)簡(jiǎn)信
IP屬地：陜西
-
2.一文搞定Kafka的生產(chǎn)者1.介紹 這篇文章就是為了幫助大家來理解Produce存在的意義以及工作的方式來進(jìn)行編寫的，整篇文章也會(huì)從整體組成媳瞪、運(yùn)行時(shí)架構(gòu)兩個(gè)方面去進(jìn)行講解...
-
1.一文搞定Kafka的組成架構(gòu)1.前言 我在之前的文章當(dāng)中粘优，介紹了很多有關(guān)于Flink的相關(guān)知識(shí)和內(nèi)容仇味。因?yàn)槲夷壳半A段所做的學(xué)習(xí)和工作的內(nèi)容就是圍繞著這一部分知識(shí)進(jìn)行的。但是...
-
9.一文搞定Flink中的重要概念
1.前言 截止到目前為止雹顺，基本上所有與FLink 中DateStream API相關(guān)的內(nèi)容都介紹完畢了丹墨，如果你一直看到這里證明很多東西你都已經(jīng)理...
-
8.一文搞定Flink單作業(yè)提交模式（per-job）的運(yùn)行時(shí)狀態(tài)1..運(yùn)行時(shí)架構(gòu) 在Flink進(jìn)行數(shù)據(jù)處理的時(shí)候，有兩個(gè)最重要的兩個(gè)組件嬉愧，分別是：作業(yè)管理器（JobManager）和任務(wù)管理器（TaskMan...
-
7.一文搞懂Flink中窗口的概念
1.前言 在上一篇文章當(dāng)中說了贩挣，如果需要進(jìn)行雙流join操作，可以選擇在窗口的范圍內(nèi)進(jìn)行，join操作會(huì)以窗口范圍內(nèi)的所有數(shù)據(jù)做inner jo...
-
6.一文搞定Flink的多流轉(zhuǎn)換
1.前言 在之前的文章當(dāng)中王财，我針對(duì)于Flink中狀態(tài)相關(guān)的一系列內(nèi)容按照我自己理解的方式進(jìn)行了講述卵迂，但是單純從我寫的內(nèi)容上看，貌似都是圍繞著單條...
-
5.一文搞定Flink中的狀態(tài)編程
1.前言 Flink一直是被成為了有狀態(tài)的流計(jì)算绒净，并且還能夠通過對(duì)狀態(tài)的合理的調(diào)控與配置见咒，來實(shí)現(xiàn)端到端的狀態(tài)一致性，實(shí)現(xiàn)數(shù)據(jù)的精準(zhǔn)一次性傳輸挂疆。這...
-
4.一文搞定：Flink與Kafka之間的精準(zhǔn)一次性
1.前言 在上一篇文章當(dāng)中改览，也算是比較詳細(xì)且通俗的聊了聊Flink是如何通過checkpoint機(jī)制來完成數(shù)據(jù)精準(zhǔn)一次性的實(shí)現(xiàn)的。并且也在上一章...
-
3.一文搞定：Flink中端到端的狀態(tài)一致性（理念）
1.前言 哈嘍缤言，大家好宝当。在第二章節(jié)中我聊了聊狀態(tài)后端和檢查點(diǎn)相關(guān)的內(nèi)容，如果你仔細(xì)看完就能夠很清楚的知道胆萧，F(xiàn)link是如何保存自己引以為傲的狀態(tài)...