Flink大数据实时计算系列-入门案例: Flink-DataStream-API-实现WordCount
- 使用DataStream实现批处理
- 使用DataStream实现流处理
- 使用DataStream根据数据源自动选择使用流还是批
package cn.itcast.hello;
import org.apache.flink.api.common.RuntimeExecutionMode;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streamin