码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • Flink—窗口、时间和水印


    Flink—窗口、时间和水印

    窗口和时间

    窗口

    Flink通过窗口数据划分不同,分为三种窗口:

    • 滚动窗口:窗口数据有固定的大小,窗口数据不会叠加
    • 滑动窗口:窗口数据有固定的大小,并且有生成间隔
    • 会话窗口:窗口数据没有固定的大小,根据用户传入的参数进行划分,窗口数据无叠加

    时间

    Flink中的时间分为三种:

    • 事件时间(Even Time):即事件实际发生的时间
    • 摄入时间(Ingestion Time):事件进入流处理框架的时间
    • 处理时间(Processing Time):事件被处理的时间
    事件时间

    事件时间指的是数据产生的时间,这个时间一般由苏韩剧生产方自身携带,如Kafka消息,每个生成的消息中自带一个时间戳代表每套数据的产生时间。事件时间从消息的产生就诞生了,不会改变,也是我们使用最频繁的时间

    利用Event Time需要指定如何生成事件时间的“水印”并且一般和窗口配合使用

    final 
    • 相关阅读:
      【JS】变量与数据类型,this
      第06章 数据挖掘综合应用
      第4周学习:MobileNetV1, V2, V3
      【ROS入门】实现参数服务器参数的增删改查操作
      全网最适合入门的面向对象编程教程:18 类和对象的 Python 实现-多重继承与 PyQtGraph 串口数据绘制曲线图
      MySQL中查询重复字段的方法和步骤是怎样
      MySQL子查询练习题 【牛客-SQL必知必会】10 使用子查询
      MySQL/SQLServer判断字符是纯数字或者是其它字符
      微信小程序写一个录音机
      第4篇 熊猫烧香逆向分析(中)
    • 原文地址:https://blog.csdn.net/weixin_54707168/article/details/126683513
    • 最新文章
    • 【JVM】编译执行与解释执行的区别是什么?JVM 使用哪种方式?
      用 Hashids 优雅解决 C 端自增 ID 暴露问题
      V8引擎 精品漫游指南--Ignition篇(上) 指令 栈帧 槽位 调用约定 内存布局 基础内容
      LLVM Pass快速入门(四):代码插桩
      milkup:桌面端 markdown AI续写和即时渲染
      基于项目工程构建SBOM(软件物料清单)的研究
      鸿蒙应用开发UI基础第二节:鸿蒙应用程序框架核心解析与实操
      .NET 中如何快速实现 List 集合去重?
      扣子Coze实战:从0到1打造抖音+小红书热点监控智能体
      浅谈数据访问层
    • 热门文章
    • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
      奉劝各位学弟学妹们,该打造你的技术影响力了!
      五年了,我在 CSDN 的两个一百万。
      Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
      面试官都震惊,你这网络基础可以啊!
      你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
      心情不好的时候,用 Python 画棵樱花树送给自己吧
      通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
      13 万字 C 语言从入门到精通保姆级教程2021 年版
      10行代码集2000张美女图,Python爬虫120例,再上征途
    小工具 小游戏
    Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1

    京公网安备 11010502049817号