本文轉(zhuǎn)自個人微信公眾號,原文鏈接。 接上篇。 使用場景 先說流計算平臺應(yīng)用場景。在我們的業(yè)務(wù)中,實時平臺核心包括幾個部分:一是大促看板,比如剛過...
投稿
收錄了6篇文章 · 11人關(guān)注
本文轉(zhuǎn)自個人微信公眾號,原文鏈接。 接上篇。 使用場景 先說流計算平臺應(yīng)用場景。在我們的業(yè)務(wù)中,實時平臺核心包括幾個部分:一是大促看板,比如剛過...
本文轉(zhuǎn)自個人微信公眾號,原文鏈接。 Apache Flink is a framework and distributed processing...
本文轉(zhuǎn)自個人微信公眾號,原文鏈接。 如 上篇 所述,F(xiàn)link 里時間包括Event Time、Processing Time 和 Ingest...
分布式流處理需求日益增加,包括支付交易、社交網(wǎng)絡(luò)、物聯(lián)網(wǎng)(IOT)、系統(tǒng)監(jiān)控等。業(yè)界對流處理已經(jīng)有幾種適用的框架來解決,下面我們來比較各流處理框...
一flink 基礎(chǔ)使用 此處主要介紹兩部分基礎(chǔ)內(nèi)容案例, 使用wiki作為連接器,讀取日志數(shù)據(jù)發(fā)送到kafka隊列 讀取socket流, 實現(xiàn)單...
1.Flink的TypeInformation類 TypeInformation是flink中所有類型的基類,其作為生產(chǎn)序列化器和比較的一個工具...