本文轉(zhuǎn)自個人微信公眾號，原文鏈接。 接上篇。 使用場景 先說流計算平臺應(yīng)用場景。在我們的業(yè)務(wù)中，實時平臺核心包括幾個部分：一是大促看板，比如剛過...
投稿
收錄了6篇文章 · 11人關(guān)注
-
2018-11-13-Flink(1)——基于flink sql的流計算平臺設(shè)計 -
2018-11-21-Flink(2)——apache flink 介紹本文轉(zhuǎn)自個人微信公眾號，原文鏈接。 Apache Flink is a framework and distributed processing...
-
2018-12-10-Flink(3)——Event Time 與 Watermark
本文轉(zhuǎn)自個人微信公眾號，原文鏈接。 如 上篇 所述，F(xiàn)link 里時間包括Event Time、Processing Time 和 Ingest...
-
實時流處理Storm、Spark Streaming、Samza、Flink對比分布式流處理需求日益增加，包括支付交易、社交網(wǎng)絡(luò)、物聯(lián)網(wǎng)（IOT）、系統(tǒng)監(jiān)控等。業(yè)界對流處理已經(jīng)有幾種適用的框架來解決，下面我們來比較各流處理框...
-
Flink基礎(chǔ)使用一flink 基礎(chǔ)使用 此處主要介紹兩部分基礎(chǔ)內(nèi)容案例， 使用wiki作為連接器，讀取日志數(shù)據(jù)發(fā)送到kafka隊列 讀取socket流， 實現(xiàn)單...
-
Flink序列化框架分析1.Flink的TypeInformation類 TypeInformation是flink中所有類型的基類，其作為生產(chǎn)序列化器和比較的一個工具...
{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/1685205/crop1542604844150.jpg', '推薦專題《flink》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/866d41d06615?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認gb2312'));){kind=link}