Flink--實時流處理框架

上圖是flink的工作流程 首先,flink從source中獲取數據,source是流入flink數據的來源,日常對接的source端有kafka,rabbitMQ等消息隊列 然後,獲取到的數據流(dataStream) 按需來進行代碼運算 最後,將上一步運算的結果數據sink到落地的模塊中,模塊可以是數據庫,也可以是服務(用戶預警報警模板)。 1、爲何選擇flink? flink是流處理模式,數
相關文章
相關標籤/搜索