使用撤回流RetractStream的场景

超、凢脫俗 2023-01-08 04:24 92阅读 0赞

### 概念图解 ###

下面来解释网上常用的一张图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FwcGxleXVjaGk_size_16_color_FFFFFF_t_70][]

我们来看上图的第二行

①以word为key,得到cnt

②以cnt为key ,得到freq

中间结果总结如下:

<table style="width:629px;"> 
 <tbody> 
  <tr> 
   <td><strong>流模式</strong></td> 
   <td style="width:140px;"><strong>数据流情况</strong></td> 
   <td style="width:158px;"><strong>中间operator结果</strong></td> 
   <td style="width:217px;"><strong>最终operator结果</strong></td> 
  </tr> 
  <tr> 
   <td colspan="1"><strong>AppendStream</strong></td> 
   <td style="width:140px;">第1条Hello到来时</td> 
   <td style="width:158px;"><img alt="" height="236" src="https://img-blog.csdnimg.cn/20210118231142127.png" width="258"></td> 
   <td style="width:217px;"><img alt="" height="139" src="https://img-blog.csdnimg.cn/20210118232709451.png" width="258"></td> 
  </tr> 
  <tr> 
   <td style="width:140px;">第2条Hello到来时</td> 
   <td style="width:158px;"><img alt="" height="228" src="https://img-blog.csdnimg.cn/20210118231931314.png" width="257"></td> 
   <td style="width:217px;"><img alt="" height="182" src="https://img-blog.csdnimg.cn/20210118232958706.png" width="258"></td> 
  </tr> 
  <tr> 
   <td colspan="1"><strong>RetractStream</strong></td> 
   <td style="width:140px;">第1条Hello到来时</td> 
   <td style="width:158px;"><img alt="" height="236" src="https://img-blog.csdnimg.cn/20210118231142127.png" width="258"></td> 
   <td style="width:217px;"><img alt="" height="139" src="https://img-blog.csdnimg.cn/20210118232709451.png" width="258"></td> 
  </tr> 
  <tr> 
   <td style="width:140px;">第2条Hello到来时</td> 
   <td style="width:158px;"><img alt="" height="228" src="https://img-blog.csdnimg.cn/20210118231931314.png" width="257"></td> 
   <td style="width:217px;"><img alt="" height="182" src="https://img-blog.csdnimg.cn/20210118233250276.png" width="252"></td> 
  </tr> 
 </tbody> 
</table>

使用场景

### 使用场景 ###

常见的使用撤回流的场景有group和join

以及上述例子中涉及到统计的一些场景需求

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FwcGxleXVjaGk_size_16_color_FFFFFF_t_70]: /images/20221119/8592d31d020f4139ad61371bc53203d9.png