Flink入门及运行

入门级程序 public class SocketWindowWordCountJava { public static void main(String[] args) throws Exception { //获取 flink 的运行环境 StreamExecutionEnvironment env = StreamExecutionEnvironme

>>阅读原文<<