然後開啟cmd視窗使用 使用命令：nc -lp 8888即可開啟監聽 8888 埠號。
如下圖：
//進行分組聚合(keyby：將key相同的分到乙個組中)
singleoutputstreamoperator> resultdatastream = wordandone.keyby(0).sum(1);
//transformation 結束
//4.呼叫sink （sink必須呼叫）
resultdatastream.print().setparallelism(1);
//5. 啟動任務執行
env.execute("stream word count");
}在命令列，輸入內容，在控制台可看到實時計算結果，效果如下圖所示：
Flink流處理之迭代案例
我們在學習flink時一般都離不開flink官網，而我們通常都要先學會 example apche的開源專案一般都會有這個目錄，今天就說一下flink的example中的流處理的迭代 官網流處理的迭代位址 首先。基於輸入流構建iterativestream。這是乙個迭代的起始。通常稱之為迭代頭 it...
Flink 流處理之source簡介
1 從集合讀取資料 定義樣例類 水位感測器 用於接收空高資料 id 感測器編號 ts 時間戳 vc 空高 case class watersensor id string,ts long,vc double object source collection 2 從檔案讀取資料 val env str...
flink學習（3） 流處理API
environment getexecutionenvironment 建立乙個執行環境，表示當前執行程式的上下文 批處理使用executionenvironment呼叫 流處理使用streamexecutionenvironment呼叫 執行環境的 變數 可以通過 setparalleism設定全...