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