Streaming System 第二章:The What- Where- When- and How of Data Processing

  1. 云栖社区>
  2. 阿里云实时计算>
  3. 博客>
  4. 正文

Streaming System 第二章:The What- Where- When- and How of Data Processing

小白薇薇 2018-12-03 13:18:01 浏览2821
展开阅读全文

本文由《Streaming System》一书第二章的提炼翻译而来,译者才疏学浅,如有错误,欢迎指正。转载请注明出处,侵权必究。

本章主要介绍鲁棒的处理乱序数据的核心概念,这些概念的运用使流处理系统超越批处理系统的关键所在。

路线图

上一章中,我们介绍了两个非常关键的概念:

  • 事件时间和处理时间,只有在事件时间维度对数据进行处理,才能保证计算结果的准确性
  • 窗口:窗口是处理无界数据流的通用方法,目前共有4类窗口。
    接下来我们介绍其他三个同样非常重要的概念:
  • 触发器(Triggers)
    触发器是决定某个窗口何时输出的一种机制。作用跟照相机的快门相同,按下去,就能拿到某个时间点计算结果的快照。通过触发器,也能多次看到某个窗口的输出结果。因此可以实现迟到数据(late event)的处理。
  • Watermark(水印)
    Watermark是描述事件时间上数据完整

网友评论

登录后评论
0/500
评论
小白薇薇
+ 关注
所属云栖号: 阿里云实时计算