博客
关于我
95-190-544-源码-window-清除器(Evictors)-DeltaEvitor简介
阅读量:110 次
发布时间:2019-02-26

本文共 196 字,大约阅读时间需要 1 分钟。

1. 视界

Flink的Window API采用松耦合设计,能够灵活定义符合特定业务需求的窗口。

2. 前文回顾

在Flink中定义窗口主要需要以下三个关键组件:窗口分配器、触发器和驱逐者。

3. 概述

在触发器触发后,驱逐者(Evictor)会在窗口处理之前剔除不需要的元素,类似于过滤器。驱逐者可以翻译为“驱逐者”,其功能是移除窗口中不必要的元素。

驱逐者剔除元素的时机是在触发器触发时。

转载地址:http://inik.baihongyu.com/

你可能感兴趣的文章
Open××× for Linux搭建之二
查看>>
Open×××有线网络时使用正常,无线网络时使用报错的解决方案
查看>>
Operation not supported on read-only collection 的解决方法 - [Windows Phone开发技巧系列1]
查看>>
Operations Manager 2007 R2系列之仪表板(多)视图
查看>>
operator new 与 operator delete
查看>>
operator() error
查看>>
OPPO K3在哪里打开USB调试模式的完美方法
查看>>
Optional类:避免NullPointerException
查看>>
ORA-00932: inconsistent datatypes: expected - got NCLOB【ORA-00932: 数据类型不一致: 应为 -, 但却获得 NCLOB 】【解决办法】
查看>>
ORA-00942 表或视图不存在
查看>>
ORA-01795: 列表中的最大表达式数为 1000
查看>>
ORA-06575: 程序包或函数 NO_VM_DROP_PROC 处于无效状态
查看>>
ORA-08102的错误
查看>>
ora-12541:tns:no listener
查看>>
【docker知识】联合文件系统(unionFS)原理
查看>>
ORACEL学习--理解over()函数
查看>>
oracle 10g crs命令,Oracle 10g CRS安装问题解决一例
查看>>
oracle 10g的安装配置
查看>>
Oracle 11.2.0.4 x64 RAC修改public/private/vip/scan地址
查看>>
Oracle 11G INDEX FULL SCAN 和 INDEX FAST FULL SCAN 对比分析
查看>>