Flink1.7.2新特性
(1)支持scala 2.12
(2) SQL 功能完善
(3)最新kafka连接器
(4)Streaming SQL新增Temporal Tables(时态表)
时态表:记录了数据发生该表的历史状态,该表可以返回特定时间点的表的内容
(5)Streaming SQL支持模式匹配
Flink CEP是Flink的复杂事件处理库,允许你在流上定义一系列的模式(pattern),最终使得你可以方便的抽取 自己需要的重要的事件处理。抽取自己需要的数据。
(6)Streaming SQL支持更多函数:REPLACE、REPEAT、LIRIM等函数
Blink 开源
阿里巴巴内部Flink 版本Blink已经开源,其最显著的特点就是强大的sql处理能力
Flink1.7.2新特性
(1)支持scala 2.12
(2) SQL 功能完善
(3)最新kafka连接器
(4)Streaming SQL新增Temporal Tables(时态表)
时态表:记录了数据发生该表的历史状态,该表可以返回特定时间点的表的内容
(5)Streaming SQL支持模式匹配
Flink CEP是Flink的复杂事件处理库,允许你在流上定义一系列的模式(pattern),最终使得你可以方便的抽取 自己需要的重要的事件处理。抽取自己需要的数据。
(6)Streaming SQL支持更多函数:REPLACE、REPEAT、LIRIM等函数
Blink 开源
阿里巴巴内部Flink 版本Blink已经开源,其最显著的特点就是强大的sql处理能力
Flink 1.7.2 开始支持支持 scala2.12,而之前只能支持到 2.11