20200604——flink datastream開發

flink流處理程序的一般流程 1)獲取flink流處理執行環境 2)構建source 3)數據處理 4)構建sink 與批處理相比 1.運行環境不同,streamexecutionenvironment 2.有些算子不同 3.程序是一直運行的,除非我們手動停止 輸入數據集data source flink中你可以使用streamexecutionenvironment.addSource(sou
相關文章
相關標籤/搜索