項目實施-13(集成Flink計算引擎)

概述 經過十一、12 篇的數據接收與處理,咱們已經拿到了標準的計算模型,以後只剩下與流計算集成,便可完成實時的用戶風險評估。java 本篇將介紹項目中引入Flink流計算框架的方案解決。mysql 總體框架 query 包中是對Flink中的可查詢的狀態數據的一些查詢展現 sql 包中是一些自定義的函數和 離線數據處理 的一些簡單示例 Flink Table api stream 包中是這次項目集
相關文章
相關標籤/搜索