1. kafka table DDL 动态table,后者定义覆盖前者, 一次创建多次使用

Flink 1.11 Table & SQL深度解读

2.clone table 完整继承、或者覆盖OPTION

Flink 1.11 Table & SQL深度解读

3.性能测试体验提升

Flink 1.11 Table & SQL深度解读

4.kafka table options 提升

Flink 1.11 Table & SQL深度解读

5.source & Sink重构

(1)ChangeLog:kafka sink 支持update delete
(2) NoMatchingFactory 异常修复
(3)table schema 类型异常

Flink 1.11 Table & SQL深度解读

6.Hive 流批一体

Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读

Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读

7.Hive Dialect

Flink 1.11 Table & SQL深度解读

Flink 1.11 Table & SQL深度解读

8.Api Client

Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读

Flink 1.11 Table & SQL深度解读

以上内容整理自2020年6月14日阿里云主办的大数据+AI meetup

相关文章:

  • 2021-08-21
  • 2021-08-23
  • 2022-02-15
  • 2021-08-24
  • 2021-07-03
  • 2021-05-17
  • 2021-06-27
  • 2019-10-25
猜你喜欢
  • 2021-06-10
  • 2022-03-02
  • 2022-12-23
  • 2021-09-23
  • 2021-09-01
  • 2021-08-22
相关资源
相似解决方案