Flink-Table StreamTableEnvironment實踐編程(四)上

在上一篇文章中掌握了StreamTableEnvironment的基本概念,下面就進入代碼實戰環節:java 1、實例中採用socket鏈接方式,獲取數據流信息,使用 nc -l 端口號方式,開啓端口監控,用來數據數據信息,實例中使用9999做爲端口,命令行中輸入:nc -l 9999 2、本實例主要功能是完成根據學生姓名實現分數統計 3、具體依賴實體類以下:     @Data     publ
相關文章
相關標籤/搜索