【大数据面试题】34 手写一个 Flink SQL 样例

本文主要是介绍【大数据面试题】34 手写一个 Flink SQL 样例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一步一个脚印，一天一道大数据面试题

博主希望能够得到大家的点赞收，藏支持！非常感谢~
点赞，收藏是情分，不点是本分。祝你身体健康，事事顺心！

我们来看看 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

这篇关于【大数据面试题】34 手写一个 Flink SQL 样例的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---