Flink之StreamTableEnvironment对象
StreamTableEnvironment对象方法简介
#1.executeSql("sql 语句")
可以执行SQL#2.sqlQuery("sql 语句")
执行SQL查询，返回查询结果#3.from("table name")
加载table到内存中#4.executeInsert("table name")
把结果插入到table中#5.createTemporaryTable("table name","table descriptor")
在内存中创建临时表
StreamTableEnvironment功能
-
Catalog管理（元数据）
Flink不比Hive，Hive的元数据是在MySQL中管理的。Flink是可以由用户来管理。
备注：
Flink里面，默认有一个catalog，名字叫：default_catalog，这个catalog在内存中。
所以，Flink中的表，它的层级关系就和MySQL、Hive、Spark不太一样。
在MySQL里，库名.表名
default.test
在Flink里，元数据库.数据库.表
default_catalog.default_database.table
-
Database，Table管理
可以创建数据库，可以创建表。
-
UDF管理（自定义函数）
StreamTableEnvironment创建方式
Flink 提供了两种创建StreamTableEnvironment的方式
-
TableEnvironment（已过期，不推荐）
EnvironmentSettings settings = EnvironmentSettings.inStramingMode().create()
TableEnvironment t_env = TableEnvironment.create(settings)-
StreamExecutionEnvironment（推荐）
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment()
StreamTableEnvironment t_env = StreamTableEnvironment.create(env)
