Flink
flink-45 UDF
UDF主要有以下几类：
标量函数 Scala Functions
一进一出
表函数 Table Functions
一进多出
聚合函数 Aggregate Functions
多进一出 聚合
表聚合函数 Table Aggre...
flink-43 catalog
catalog提供了元数据信息，例如数据库、表、分区、视图以及其他外部系统中存储的函数和信息
catalog允许用户引用数据存储系统中现有的元数据，并自动将其映射到flink的相应元数据，比如flink使用hive metastore
目前flink包含以下...
flink-41 常用Connector读写
需要注意 服务器上 flink客户端依赖和idea中编码依赖有不同
只要修改依赖，修改配置 都需要重启yarn-session和sql-client
普通kafka表
创建kafka的映射表
flink-40 Module操作
Module允许flink扩展函数能力
目前flink包含了以下三种module：
CoreModule
flink内置module
包含flink内置的所有UDF
HiveModule
可以讲Hive内置函数作为flink的系统函数提...
flink-37 Flink sql 时间属性
所谓的时间属性，其实就是每个表schema的一部分，它可以在创建表的DDL里直接定义一个字段，也可以在DataStream转换成表时定义。
一旦定义了时间属性，它就可以作为一个普通的字段引用，并且可以在基于时间的操作中使用。
时间属性数据类型为TIMEST...