本文大綱1 RichFunction2 RichMapFunction3 state4 keyed state4.1 keyedState簡(jiǎn)單示...
投稿
收錄了19篇文章 · 7人關(guān)注
-
Flink RichFunction&state -
Flink DataStream API詳解Flink API介紹 Flink提供了三層API，每層在簡(jiǎn)潔性和表達(dá)性之間進(jìn)行了不同的權(quán)衡。 ProcessFunction是Flink提供的...
-
Flink 原理與實(shí)現(xiàn)：內(nèi)存管理如今，大數(shù)據(jù)領(lǐng)域的開(kāi)源框架（Hadoop，Spark，Storm）都使用的 JVM，當(dāng)然也包括 Flink?；?JVM 的數(shù)據(jù)分析引擎都需要面...
-
【Flink】Flink集群部署與YARN集成
1、Standalone 軟件要求： Java 1.8.x or higher ssh JAVA_HOME配置 You can set this...
-
玩轉(zhuǎn)KafkaIO與Flink隨著大數(shù)據(jù) 2.0 時(shí)代悄然到來(lái)，大數(shù)據(jù)從簡(jiǎn)單的批處理擴(kuò)展到了實(shí)時(shí)處理、流處理、交互式查詢(xún)和機(jī)器學(xué)習(xí)應(yīng)用。近年來(lái)涌現(xiàn)出諸多大數(shù)據(jù)應(yīng)用組件，如 H...
-
Flink：特性、概念、組件棧、架構(gòu)及原理分析
簡(jiǎn)單之美 | Apache Flink：特性、概念、組件棧、架構(gòu)及原理分析http://shiyanjun.cn/archives/1508.h...
-
Operators原文鏈接 操作符將一個(gè)或多個(gè)DataStream轉(zhuǎn)換成為新的DataStream。程序可以將多個(gè)轉(zhuǎn)換組合成復(fù)雜的數(shù)據(jù)流拓步。 本節(jié)給出了基本轉(zhuǎn)換...
-
Event Time原文鏈接 事件時(shí)間 /處理時(shí)間/攝入時(shí)間 Flink支持流操作中不同的時(shí)間概念。 處理時(shí)間: 處理時(shí)間是指執(zhí)行相應(yīng)操作的機(jī)器的系統(tǒng)時(shí)間。當(dāng)流程序...
-
Checkpoints
原文鏈接 概述 Checkpoint通過(guò)允許從狀態(tài)和相應(yīng)流的位置進(jìn)行恢復(fù)，從而使Flink中的狀態(tài)具備容錯(cuò)能力，從而使應(yīng)用程序具有與無(wú)故障執(zhí)行相...
-
Checkpointing
原文鏈接 Flink中的每個(gè)函數(shù)和操作符都可以是有狀態(tài)的(詳細(xì)信息請(qǐng)參閱使用狀態(tài))。有狀態(tài)的函數(shù)在單個(gè)元素/事件的處理過(guò)程中存儲(chǔ)數(shù)據(jù)，使?fàn)顟B(tài)成為...
{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/1709158/1547480041.jpg', '推薦專(zhuān)題《flink》（ 分享自 @簡(jiǎn)書(shū) ）','http://www.itdecent.cn/c/ed16d738d037?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁(yè)面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}