码农知识堂 - 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 
    • 相关阅读:
      技术人员如何有效进行各种职场排挤、防止被排挤?
      SSM项目 - Online Music Player(在线音乐播放器)- 前端页面设计 - 细节狂魔
      基于ssm的学生成绩分析系统maven idea
      搭建一款实用的个人IT工具箱——it-tools
      一文搞懂V8引擎的垃圾回收机制
      人体神经元与胶质关系图,神经元和神经胶质关系
      SPI 应用
      1分钟 Serverless 极速搭建真网站 领猫超卡之《极速搭建 Zblog 博客系统》场景体验
      Spring-IOC配置-bean
      画法几何及机械制图复习题及答案
    • 原文地址:https://blog.csdn.net/weixin_54707168/article/details/126683513
    • 最新文章
    • 攻防演习之三天拿下官网站群
      数据安全治理学习——前期安全规划和安全管理体系建设
      企业安全 | 企业内一次钓鱼演练准备过程
      内网渗透测试 | Kerberos协议及其部分攻击手法
      0day的产生 | 不懂代码的"代码审计"
      安装scrcpy-client模块av模块异常,环境问题解决方案
      leetcode hot100【LeetCode 279. 完全平方数】java实现
      OpenWrt下安装Mosquitto
      AnatoMask论文汇总
      【AI日记】24.11.01 LangChain、openai api和github copilot
    • 热门文章
    • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
      奉劝各位学弟学妹们,该打造你的技术影响力了!
      五年了,我在 CSDN 的两个一百万。
      Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
      面试官都震惊,你这网络基础可以啊!
      你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
      心情不好的时候,用 Python 画棵樱花树送给自己吧
      通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
      13 万字 C 语言从入门到精通保姆级教程2021 年版
      10行代码集2000张美女图,Python爬虫120例,再上征途
    Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1
    正则表达式工具 cron表达式工具 密码生成工具

    京公网安备 11010502049817号