Flink - 11.Scala/Java trigger 简介与使用

一.引言

Flink 使用 windowAll 生成 AllwindowedStream 后调用 Trigger 执行窗口触发逻辑，下面对 Trigger 触发器做一个基本的了解。

二.Trigger 简介

Trigger 翻译为触发，扳机，其作用为在一定条件下触发窗口进行计算，如果是内部 operator 则执行对应 operator，如果自定义实现了 ProcessAllWindowFunction，则触发自定义执行逻辑。触发器决定窗口(由窗口赋值器形成)何时准备由窗口函数处理。每个WindowAssigner都有一个默认的触发器。如果默认触发器不符合您的需要，您可以使用trigger(…)指定一个自定义触发器。Trigger 多见于将大窗口的数据实时输出，例如针对 100s 的窗口，每 10s 触发一次数据执行窗口逻辑。

1.触发器方法

· onElement

public abstract TriggerResult onElement(T var1, long var2, W var4, Trigger.TriggerContext var5) throws Exception;

对于添加到窗口中的每个元素，都会调用onElement()方法。以最基础的 CountTrigger 为例，每当元素到达，对应 Trigger 类都会进行计数器累加和判断，如果到达数量累加至对应 count，则进行触发执行一次窗口逻辑。

· onEventTime

public abstract TriggerRe

最后

以上就是呆萌星星为你收集整理的Flink - 11.Scala/Java trigger 简介与使用的全部内容，希望文章能够帮你解决Flink - 11.Scala/Java trigger 简介与使用所遇到的程序开发问题。

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