Flink學習筆記(三)——監控維基百科編輯流

本文參考官方文檔,使用flink 提供的API,在flink集羣上運行流式分析。java 維基百科提供了一個IRC頻道,對全部的wiki的編輯都會被記錄下來。並計算每一個用戶在給定時間窗口內編輯的字節數。使用flink實現這個功能只須要幾分鐘,並且很是的簡單,同時也爲後面學習更復雜的程序打下基礎。git 已上傳至github: https://github.com/KeoZmy/wiki-flin
相關文章
相關標籤/搜索