Flink批處理和流處理兩種方式實現WordCount代碼示例

使用scala實現批處理和流處理的wordcount示例 編寫scala版本批處理wordcount 1.新建maven項目 2.導入pom座標 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-scala_2.11</artifactId> <version>1.3.2

>>阅读原文<<