Flink会话窗口测试

一、测试结论：

1、会话窗口的间隔时间和水位线作用一样，表示输出现在时间 - 间隔时间之前所有未结算时间的数据，作用类似于水位线，但是和水位线开闭不一样。

2、会话窗口显示的数据是[上一个时间 - 水位线 - 间隔时间+2ms ~ 现在的时间 - 水位线 - 间隔时间+1ms]之间的数据，注意左右都是闭区间。

二、测试数据：

设定:

水位线4s：new BoundedOutOfOrdernessTimestampExtractor[String](Time.seconds(4))

间隔时间5s：EventTimeSessionWindows.withGap(Time.seconds(5))

数据如下：

最新文章

  1. caffe-mnist别手写数字
  2. SRM 615 DIV1 500
  3. UGUI之Toggle使用
  4. Week2学习过程报告
  5. java 文件读取大全
  6. \u202e
  7. firefox HackBar组件模拟请求POST请求
  8. 【LeetCode练习题】Reverse Linked List II
  9. javascript基础数据类型与引用类型
  10. Node.js系列-http
  11. Android开发小问题集
  12. eclipse 中修改项目名称，启动tomct原项目找不到的问题
  13. css3实现小程序的动画
  14. ubuntu16.04安装Navicate
  15. 关于实现udev/mdev自动挂载与卸载
  16. Difference Between Session.run and Tensor.eval
  17. 关于ADO.Net SqlConnection的性能优化
  18. The following packages have unmet dependencies错误
  19. JMX超详细解读<转>
  20. SQL中SELECT INTO和INSERT INTO SELECT语句介绍

热门文章

  1. opencart源码解析之 index.php
  2. 赵伟国：陆资无法进入台湾紫光要到WTO控告（芯片是为了经济安全，高通找的人不是很聪明）
  3. LINQ查询表达式---------from子句
  4. Android零基础入门第57节：日期选择器DatePicker和时间选择器TimePicker
  5. QT编译./configure参数的详细解释
  6. 各种 MacBook 和 5K iMac 屏幕分辨率对比
  7. CSS3 GENERATOR可以同时为一个元素完成border-radius、box-shadow、gradient和opacity多项属性的设置
  8. 初涉Delphi Socket编程
  9. FMX中实现PostMessage的方法
  10. arcgis api for js 4.X 出现跨域问题