95-190-438-源码-window-Trigger-总体概述1.视界2.前文回顾3.概述

200 阅读 0 评论 132 点赞

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

1.视界

在这里插入图片描述

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

Window Assigner
Trigger
Evictor

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

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

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

在这里插入图片描述

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

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