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

>>阅读原文<<