Flink Table&SQL API的簡單使用

1.需求 從csv文件中讀取數據並保存爲數據表 執行sql語句進行查詢並輸出 2.分析程序運行步驟 獲取flink的執行環境，咱們這裏用的是批處理的執行環境 獲取table的執行環境，這裏也獲取的是批處理的執行環境 從csv文件中讀取數據，以POJO的形式接收，返回DataSet 對flink如何從csv文件讀取數據不清楚的朋友能夠看我這篇博客！ http://www.javashuo.com/a

>>阅读原文<<