1 概覽 1.1 預(yù)定義的源和接收器 Flink內(nèi)置了一些基本數(shù)據(jù)源和接收器，并且始終可用。該預(yù)定義的數(shù)據(jù)源包括文件，目錄和插socket，并...
投稿
收錄了6篇文章 · 3人關(guān)注
-
Flink實戰(zhàn)(八) - Streaming Connectors 編程 -
Flink實戰(zhàn)(六) - Table API & SQL編程
1 意義 1.1 分層的 APIs & 抽象層次 Flink提供三層API。 每個API在簡潔性和表達(dá)性之間提供不同的權(quán)衡，并針對不同的用例。...
-
Flink實戰(zhàn)(七) - Time & Windows編程
0 相關(guān)源碼 掌握Flink中三種常用的Time處理方式，掌握Flink中滾動窗口以及滑動窗口的使用，了解Flink中的watermark。 F...
-
Flink實戰(zhàn)(五) - DataStream API編程1 概述 Flink中的DataStream程序是實現(xiàn)數(shù)據(jù)流轉(zhuǎn)換的常規(guī)程序（例如，過濾，更新狀態(tài)，定義窗口，聚合）。 最初從各種源（例如，消息...
-
Flink實戰(zhàn)(四) - DataSet API編程1 你將學(xué)到 ◆ DataSet API開發(fā)概述 ◆ 計數(shù)器 ◆ DataSource ◆ 分布式緩存 ◆ Transformation ◆ S...
-
Apache Flink實戰(zhàn)(一) - 初識Flink了解Flink是什么，F(xiàn)link應(yīng)用程序運行的多樣化，對比業(yè)界常用的流處理框架，F(xiàn)link的發(fā)展趨勢，F(xiàn)link生態(tài)圈，F(xiàn)link應(yīng)用場景及Fl...
{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/1751358/flink.jpeg', '推薦專題《Flink》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/2c16fb51cf12?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}