1.视界

2.概述

 周期性水印生成的另一个例子是当水印滞后的最大时间戳在数据流中被认为是一个固定的时间，在这种情况下，在数据流中遇到的最大延迟是已知的。

例如，创建一个带时间戳的并在一个固定的时间内传播的元素的测试源。对于这些情况，Flink 提供了BoundedOutOfOrdernessTimestampExtractor，以maxOutOfOrderness作为参数，这个maxOutOfOrderness是指在窗口计算的最后，一个元素允许的最大延迟时间。

延迟与t-t_w的结果相对应，这里t指的是元素的timestamp，而t_w指的是上个水印。如果延迟>0 那么这个元素被认为是延迟的，默认情况下，这个元素不计入窗口的最终计算中。

程序


DataStream<MyEvent> stream =

95-180-050-源码-Watermark-允许固定数量延迟的分配器(BoundedOutOfOrdernessTimestampExtractor)相关推荐

LDD3源码分析之时间与延迟操作
作者:刘昊昱博客:http://blog.csdn.net/liuhaoyutz 编译环境:Ubuntu 10.10 内核版本:2.6.32-38-generic-pae LDD3源码路径:exam ...
Hadoop源码解析之Mapper数量计算公式
前言据说,自0.20.0版本开始,Hadoop同时提供了新旧两套MapReduce API,并在后续版本中也同时支持这两种API的使用.新版本MR API在旧的基础进行了扩展,也制定了新的split ...
绝地求生服务器延迟检测源码,绝地求生不停网络延迟检测怎么办绝地求生网络问题解决办法...
每个游戏玩家在游戏中都会遇到延迟卡顿的现象,最近许多朋友在玩绝地求生的时候出现一直网络延迟检测,这是怎么回事呢?下面小编介绍一下解决的办法,让你们畅快的吃鸡. 1.首先设置游戏的启动项:-USEALL ...
opencv源码解析之(6)：hog源码分析
一.网上一些参考资料在博客目标检测学习_1(用opencv自带hog实现行人检测) 中已经使用了opencv自带的函数detectMultiScale()实现了对行人的检测,当然了,该算法采 ...
精美jQuery插件及源码前端开发福利
jQuery是一个非常不错的javascript框架,很多前端开发者喜欢的原因不仅是因为jQuery使用起来方便,更重要的是因为它的插件很多,我们可以将这些插件应用到自己的项目中去.下面这些精美的jQ ...
10款经典的web前端特效的预览及源码
1.CSS3响应式导航菜单今天我给大家介绍一下如何使用纯CSS来实现的一个响应式导航菜单,我们使用的是HTML5+CSS3技术,当浏览器窗口变小或者使用手机浏览器访问的时候,原本横条菜单会收缩成一个 ...
【珍藏】 2012.NET开发必看资料53个+经典源码77个—下载目录
2019独角兽企业重金招聘Python工程师标准>>> .NET 是 Microsoft XML Web services 平台.XML Web services 允许应用程序通过I ...
web前端的十种jquery特效及源码下载
1.纯CSS3实现自定义Tooltip边框涂鸦风格这是一款用纯CSS3打造的自定义Tooltip边框的应用,之前我们讨论过如何用CSS3来实现不同样式的Tooltip,今天的这款Tooltip却可 ...
超酷震撼 HTML5/CSS3动画应用及源码
HTML5可以制作非常华丽的动画效果,这点通过之前的分享学习我们已经有深刻的了解了,今天我们主要来分享一些HTML5结合CSS3形成的超炫震撼的动画应用以及它们的源代码,真的非常不错. 1.纯CSS3 ...

95-180-050-源码-Watermark-允许固定数量延迟的分配器(BoundedOutOfOrdernessTimestampExtractor)

1.视界

2.概述

95-180-050-源码-Watermark-允许固定数量延迟的分配器(BoundedOutOfOrdernessTimestampExtractor)相关推荐

最新文章

热门文章