0
点赞
收藏
分享

微信扫一扫

大数据_Flink_Java版_数据处理_Window_API(3)_计数窗口测试---Flink工作笔记0048

ZSACH 2022-03-14 阅读 57

可以看到这里trigger这个触发器,这个已经接触过了,他可以定义,window什么时候关闭,触发计算并输出结果.

然后这个.evictor就是,移出流过来的数据中的,一些不符合要求的数据.

首先我们去看看和这个,trigger怎么用,可以看到,就是.trigger,然后new Trigger对吧.

然后再看这里有个.evictor这个移除器,可以看到也是new Evictor,就可以用了对吧.

这两个自己看一下,一般用的不多.

举报

相关推荐

0 条评论