Flink-Table SQL 實踐編程 StreamTableEnvironment（十）下

StreamTableEnvironment主要是流式數據處理，本文主要實現GroupBy Window Aggregation、Over Window aggregation對應sql api的代碼實現，同時實現流數據表join 鏈接。java 代碼中使用socket方式做爲source數據輸入方式，閒話不說，具體代碼以下：sql 1、依賴的實體類以及ScalarFunction信息：apach

>>阅读原文<<