Flink窗口类型功能汇总

Flink窗口类型功能汇总

Flink 中的 WindowAssigner 有多种实现类,每种实现类都有不同的作用。以下是一些常见的 WindowAssigner 实现类:


  1. TumblingEventTimeWindows:
    将事件时间划分为固定大小的窗口。
  1. SlidingEventTimeWindows:
    将事件时间划分为固定大小的窗口,但窗口之间存在重叠。
  1. SessionWindows:
    将事件时间划分为会话窗口,会话窗口由连续的事件组成,当一段时间内没有事件发生时,会话窗口结束。
  1. GlobalWindows:
    将整个数据流视为一个窗口。
  1. ProcessingTimeWindows:
    将处理时间划分为固定大小的窗口。
  1. SlidingProcessingTimeWindows:
    将处理时间划分为固定大小的窗口,但窗口之间存在重叠。
  1. CountWindows:
    将数据流划分为固定数量的元素的窗口。
  1. SlidingCountWindows:
    将数据流划分为固定数量的元素的窗口,但窗口之间存在重叠。
  1. DynamicCountWindows:
    将数据流划分为固定数量的元素的窗口,但窗口的大小可以动态调整。
  1. DynamicSlidingCountWindows:
    将数据流划分为固定数量的元素的窗口,但窗口的大小可以动态调整,并且窗口之间存在重叠。

相关推荐

  1. Flink窗口类型功能汇总

    2024-01-26 07:42:02       32 阅读
  2. Flink-时间窗口

    2024-01-26 07:42:02       49 阅读
  3. PostgreSQL 窗口函数汇总

    2024-01-26 07:42:02       16 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-01-26 07:42:02       18 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-01-26 07:42:02       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-01-26 07:42:02       19 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-01-26 07:42:02       20 阅读

热门阅读

  1. Linux CentOS安装Subversion(SVN)(svn常用命令)

    2024-01-26 07:42:02       30 阅读
  2. eclipse中导入运行MyEclipse项目...非常实用

    2024-01-26 07:42:02       30 阅读
  3. hadoop 问题集

    2024-01-26 07:42:02       38 阅读
  4. com.sun.jna.platform.mac.SystemB$Timeval

    2024-01-26 07:42:02       30 阅读
  5. linux 内核MAC 地址解析

    2024-01-26 07:42:02       32 阅读
  6. nrm-npm包版本管理和详细安装和使用教程

    2024-01-26 07:42:02       35 阅读
  7. 使用uniApp+vue3+Vite4+pinia+sass技术栈构建微信小程序

    2024-01-26 07:42:02       34 阅读
  8. SpringBoot ResponseBodyAdvice使用以及常见问题

    2024-01-26 07:42:02       33 阅读
  9. 前端学习之——react篇(条件渲染)

    2024-01-26 07:42:02       46 阅读