美文网首页
Window窗口增量/全量聚合方法(reduce、aggrega

Window窗口增量/全量聚合方法(reduce、aggrega

作者: 程序男保姆 | 来源:发表于2020-07-28 14:32 被阅读0次
  • 增量聚合
    指窗口每进入一条数据就计算一次


    image.png

实现方法


image.png

举例
reduce


image.png

aggregate


image.png
  • 全量聚合
    指在窗口触发的时候才会对窗口内的所有数据进行一次计算(等窗口的数据到齐,才开始进行聚合计算,可实现对窗口内的数据进行排序等需求)


    image.png

实现方法
apply(windowFunction)
process(processWindowFunction)
举例
apply

image.png

process


image.png

相关文章

网友评论

      本文标题:Window窗口增量/全量聚合方法(reduce、aggrega

      本文链接:https://www.haomeiwen.com/subject/hdufrktx.html