我是靠谱客的博主 强健口红,最近开发中收集的这篇文章主要介绍95-190-438-源码-window-Trigger-总体概述1.视界2.前文回顾3.概述,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

1.视界

在这里插入图片描述

2.前文回顾

得益于 Flink Window API 松耦合设计,我们可以非常灵活地定义符合特定业务的窗口。Flink 中定义一个窗口主要需要以下三个组件

Window Assigner
Trigger
Evictor

3.概述

**Trigger:**触发器。决定了一个窗口何时能够被计算或清除,每个窗口都会拥有一个自己的Trigger。

Trigger(触发器)用于决定某个窗口的元素集合什么时候触发计算以及结果什么时候被emit。

如下类图展示了目前内置实现的 Triggers:

在这里插入图片描述

以粗粒度来看,Flink主要提供了三种形式的触发方式:

最后

以上就是强健口红为你收集整理的95-190-438-源码-window-Trigger-总体概述1.视界2.前文回顾3.概述的全部内容,希望文章能够帮你解决95-190-438-源码-window-Trigger-总体概述1.视界2.前文回顾3.概述所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(44)

评论列表共有 0 条评论

立即
投稿
返回
顶部