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

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

1. 视界

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

2. 前文回顾

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

3. 概述

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

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

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

你可能感兴趣的文章
OpenPPL PPQ量化(4):计算图的切分和调度 源码剖析
查看>>
OpenPPL PPQ量化(5):执行引擎 源码剖析
查看>>
openpyxl 模块的使用
查看>>
OpenResty & Nginx:详细对比与部署指南
查看>>
OpenResty(nginx扩展)实现防cc攻击
查看>>
openresty完美替代nginx
查看>>
Openresty框架入门详解
查看>>
OpenResty(1):openresty介绍
查看>>
OpenResty(2):OpenResty开发环境搭建
查看>>
OpenResty(3):OpenResty快速入门之安装lua
查看>>
OpenResty(4):OpenResty快速入门
查看>>
OpenResty(5):Openresty 模板渲染
查看>>
OpenSearch 使用二三事
查看>>
OpenSessionInView模式
查看>>
openshift搭建Istio企业级实战
查看>>
OpenSLL
查看>>
Openssh Openssl升级
查看>>
openssh 加固
查看>>
ViewPager切换滑动速度修改
查看>>
OpenSSL 引入了新的治理模式和项目,来增强社区参与和决策
查看>>