一步一個腳印，一天一道大數據面試題

博主希望能夠得到大家的點贊收，藏支持！非常感謝~
點贊，收藏是情分，不點是本分。祝你身體健康，事事順心！

我們來看看 Flink SQL大概流程和樣例：

流程：

1.創建 流處理環境 StreamExecutionEnvironment env
2.創建 表環境 StreamTableEnvironment.create(env);
3.創建 source表，sink 表
4.用 table API 編寫查詢 SQL（返回 Table 對象）
5.執行 sink executeInsert("sink")

代碼樣例：

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironm