wol/TheKingOfBigData
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新flink的文章的排版

Browse Source
This commit is contained in:
wenjunzhou 2021-02-23 16:31:50 +08:00
parent 0512699899
commit 010bc86293
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
note/flink/FlinkSQL流处理中的特殊概念.md
View File

@ -81,7 +81,7 @@
        下图显示了将动态表转换为 Retract 流的过程。
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210117102643561.png?,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMxODgzMA==,size_16,color_FFFFFF,t_70#pic_center)
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210117102643561.png?,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMxODgzMA==,size_16,color_FFFFFF,t_70)
- **Upsert（更新插入）流**
        Upsert 流包含两种类型的消息：Upsert 消息和 delete 消息。转换为 upsert 流的动态表，需要有唯一的键（key）。
@ -90,8 +90,10 @@
        下图显示了将动态表转换为 upsert 流的过程。
![在这里插入图片描述](https://img-blog.csdnimg.cn/2021011710302610.png?,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMxODgzMA==,size_16,color_FFFFFF,t_70#pic_center)
        这些概念我们之前都已提到过。需要注意的是，在代码里将动态表转换为DataStream时，仅支持 Append 和Retract流 。而向外部系统输出动态表的TableSink接口，则可以有不同的实现，比如之前我们讲到的ES，就可以有Upsert模式。
![在这里插入图片描述](https://img-blog.csdnimg.cn/2021011710302610.png?,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMxODgzMA==,size_16,color_FFFFFF,t_70)
        
​ 这些概念我们之前都已提到过。需要注意的是，在代码里将动态表转换为DataStream时，仅支持 Append 和Retract流 。而向外部系统输出动态表的TableSink接口，则可以有不同的实现，比如之前我们讲到的ES，就可以有Upsert模式。
### 2.4 时间特性
        基于时间的操作（比如 Table API 和 SQL 中窗口操作），需要定义相关的时间语义和时间数据来源的信息。所以，**Table可以提供一个逻辑上的时间字段，用于在表处理程序中，指示时间和访问相应的时间戳**。