95-110-040-源码-Env-StreamTableEnvironment

1.视界

在这里插入图片描述

2.概述

TableEnvironment是Table API和SQL集成的核心概念,他主要负责:

1. 在Table内部目录中注册表
2. 注册一个外部表
3. 执行SQL查询
4. 注册用户行为的(标量,表或聚合)函数
5. 将DataStream或者DataSet转换为Table
6. 持有对ExecutionEnvironment或的引用StreamExecutionEnvironment

​ 表始终绑定到特定的TableEnvironment。 不可能在同一查询中组合不同TableEnvironments的表,例如,加入或联合它们。

​ 通过使用StreamExecutionEnvironment或ExecutionEnvironment和可选的TableConfig调用静态BatchTableEnvironment.create()StreamTableEnvironment.create()方法来创建TableEnvironment。 TableConfig可用于配置TableEnvironment或自定义查询优化和转换过程.

2.1 个 TableEnvironment 梳理

​ 在 Flink 1.8

猜你喜欢

转载自blog.csdn.net/qq_21383435/article/details/105442088
env
110
95