flink 源码解析

拼搏现实的明天。 2022-09-10 15:09 194阅读 0赞

[https://www.cnblogs.com/Springmoon-venn/p/14551983.html][https_www.cnblogs.com_Springmoon-venn_p_14551983.html]

watermark的时间两种方式：

[https://blog.csdn.net/lvwenyuan\_1/article/details/91389124][https_blog.csdn.net_lvwenyuan_1_article_details_91389124]

如果是process-time则一定要设置 setAutoWatermarkInterval，

getConfig().setAutoWatermarkInterval(200);

而event-time会自动设置 getConfig().setAutoWatermarkInterval(200);。

@PublicEvolving
    	public void setStreamTimeCharacteristic(TimeCharacteristic characteristic) {
    		this.timeCharacteristic = Preconditions.checkNotNull(characteristic);
    		if (characteristic == TimeCharacteristic.ProcessingTime) {
    			getConfig().setAutoWatermarkInterval(0);
    		} else {
    			getConfig().setAutoWatermarkInterval(200);
    		}
    	}

[https_www.cnblogs.com_Springmoon-venn_p_14551983.html]: https://www.cnblogs.com/Springmoon-venn/p/14551983.html
[https_blog.csdn.net_lvwenyuan_1_article_details_91389124]: https://blog.csdn.net/lvwenyuan_1/article/details/91389124

发表评论取消回复

表情：

评论列表（有 0 条评论，194人围观）

还没有评论，来说两句吧...

相关阅读

相关 flink jobgraph源码解析

1、 api到executiongraph的整个流程 [https://zhuanlan.zhihu.com/p/22736103][https_zhuanlan.zhih

╰+攻爆jí腚メ/ 2022年10月06日 05:56/ 0 赞/ 136 阅读

相关 flink 源码解析

[https://www.cnblogs.com/Springmoon-venn/p/14551983.html][https_www.cnblogs.com_Springmo

拼搏现实的明天。/ 2022年09月10日 15:09/ 0 赞/ 195 阅读

相关 HashMap源码解析

一、HashMap概述　　HashMap基于哈希表的 Map 接口的实现。此实现提供所有可选的映射操作，并允许使用 null 值和 null 键。（除了不同步

不念不忘少年蓝@/ 2022年07月12日 14:07/ 0 赞/ 349 阅读

相关 webpack 源码解析

webpack 源码解析序言项目上在使用webpack，感叹真是神器，既然是神器，就想探知究竟。总览 webpack整体是一个插件架构，所有的功能都以

青旅半醒/ 2022年06月02日 09:20/ 0 赞/ 369 阅读

相关 EventBus源码解析

事件注册根据前一讲EventBus使用详解我们已经知道EventBus使用首先是需要注册的，注册事件的代码如下：

本是古典何须时尚/ 2022年06月01日 06:43/ 0 赞/ 327 阅读

相关 HashMap源码解析

来不及整理电子版，先献丑把笔记本拍几张，随后整理。有人问，什么年代了，还手写笔记，哈哈，如果不亲自手写一遍，我是真心记不住。很多API不用知道工作原理一样可以使用，所以

本是古典何须时尚/ 2022年05月10日 03:50/ 0 赞/ 357 阅读

相关 HashMap源码解析

源码博客相关博客写了那么多，突然想起来都没有写一篇我们日常开发中最常见的HashMap,今天简单补一下！ HashMap简介： `HashMap` 是应用更加广泛的哈希

左手的ㄟ右手/ 2022年04月22日 06:08/ 0 赞/ 385 阅读

相关 LinkedList源码解析

介绍上一篇中ArrayDeque为数组实现的Deque，LinkedList为用链表实现的（和大学时学的链表操作是一样的，没有任何的区别）。 1. 双链表实现了Li

╰+攻爆jí腚メ/ 2022年04月06日 04:58/ 0 赞/ 294 阅读

相关 HashMap源码解析

以下针对JDK 1.8版本中的HashMap进行分析。概述哈希表基于`Map`接口的实现。此实现提供了所有可选的映射操作，并且允许键为`null`，值也为`null

太过爱你忘了你带给我的痛/ 2022年04月05日 10:13/ 0 赞/ 466 阅读

相关 hashMap源码解析

源码来自jdk：1.8，和其他jdk版本可能有少许差异。一.hashMap的实现原理 hashMap底层是一个有Node组成的数组，每个Node都有一个key

冷不防/ 2022年03月25日 06:58/ 0 赞/ 429 阅读