1.概述

flink中的时间是如何设置的呢？

1.1 主要的类

1.1.1 AbstractStreamOperator

flink流中的核心类，所有流操作的基本抽象类，包含了一个operator的生命周期，里面有一个关于时间服务的manager的属性InternalTimeServiceManager

1.1.2 InternalTimeServiceManager

flink 内部提供时间服务的manager

核心方法：

getInternalTimerService：负责注册一个时间服务类型InternalTimeService
advanceWatermark：添加watermark
snapshotStateForKeyGroup：对InternalTimeService进行checkpoint
restoreStateForKeyG

【Flink】Flink时间是如何设计的相关推荐

Flink的时间语义和Watermark
1 时间语义数据迟到的概念是:数据先产生,但是处理的时候滞后了在Flink的流式处理中,会涉及到时间的不同概念,如下图所示: Event Time:是事件创建的时间.它通常由事件 ...
Flink DataStream时间水印机制
专栏原创出处:github-源笔记文件 ,github-源码 ,欢迎 Star,转载请附上原文出处链接和本声明. 本节内容对应官方文档 ,本节内容对应示例源码 1 Time(时间) 所有由 Flink ...
Flink事件时间、水印以及迟到数据处理的个人理解
Flink中的时间概念 Flink在流式传输程序中支持不同的时间概念: ProcessingTime: 处理时间,正在执行操作的机器的时间 EventTime: 事件时间,事件发生的时间 Ingest ...
【Flink】Flink Flink 1.14 新特性预览
1.概述转载:Flink 1.14 新特性预览简介: 一文了解 Flink 1.14 版本新特性及最新进展本文由社区志愿者陈政羽整理,内容源自阿里巴巴技术专家宋辛童 (五藏) 在 8 月 7 日 ...
凌波微步Flink——Flink的技术逻辑与编程步骤剖析
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/95459606 本文出自[我是干勾鱼的博客] Ingredients: Java: ...
大数据计算引擎之Flink Flink CEP复杂事件编程
原文地址:大数据计算引擎之Flink Flink CEP复杂事件编程复杂事件编程(CEP)是一种基于流处理的技术,将系统数据看作不同类型的事件,通过分析事件之间的关系,建立不同的时事件系序列库,并利 ...
时间轴ui设计_我应该在UI设计上花更多时间吗？
时间轴ui设计 Let's start with an example of communication skills: they are important for any profession, ...
寻找时间轴网页设计灵魂
我敢肯定,你们中的大多数都知道在设计中使用时间轴的,尤其是 Facebook 个人主页改版成这样之后,这种风格更加流行.此外,像 Path 和 Tweetbot 也在一些智能手机应用程序使用基于时间轴 ...
极客时间_软件设计之美笔记
极客时间_软件设计之美笔记 1.软件设计是什么写代码前应该有模型设计比如mvc结构就是一种模型代码应该有规范, 产品内部原则避免每个开发按自己的想法实现,有人写rest 有人写mvc 代码模 ...
凌波微步Flink——Flink API中的一些基础概念
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/95355619 本文出自[我是干勾鱼的博客] Ingredients: Java: ...

【Flink】Flink时间是如何设计的

1.概述

1.1 主要的类

1.1.1 AbstractStreamOperator

1.1.2 InternalTimeServiceManager

【Flink】Flink时间是如何设计的相关推荐

最新文章

热门文章