Flink入門及運行

入門級程序 public class SocketWindowWordCountJava { public static void main(String[] args) throws Exception { //獲取 flink 的運行環境 StreamExecutionEnvironment env = StreamExecutionEnvironme

>>阅读原文<<