`import org.apache.flink.api.java.operators.DataSource;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import javax.net.ssl.HostnameVerifier;
public class StreamWordCount {
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(2);
String inputPath = “D:resourceshello.txt”;
DataStreamSource inputDataStream = env.readTextFile(inputPath);
//DataStreamSource SocketInputStream = env.socketTextStream(“localhost”, 9999);
//生产环境代码 不能写死端口
//ParameterTool parameterTool = ParameterTool.fromArgs(args);
//String host = parameterTool.get(“host”);
//int port = parameterTool.getInt(“port”);
inputDataStream.flatMap(new WordCount.MyFlatMapper()).keyBy(0).sum(1).print();
env.execute();
}
}`
