类型参数 我们发现，如果窗口的时间是处理时间就调用滑动处理时间窗口，我们在代码中设置了事 ...

1.时间语义 Flink是一个实时计算引擎，谈到实时概念，就必然会设计到时间概念。Flink的时间语义是保证实时及实时数据处理的一致性，及时性。Flink时间语义分为下面三种 Event Time:事件创建时间 Ingestion Time:事件摄入时间(数据进入Flink的时间 ...

什么是水位线 在事件时间语义下，我们不依赖系统时间，而是基于数据自带的时间戳去定义了一个时钟，用来表示当前时间的进展。于是每个并行子任务都会有一个自己的逻辑时钟，它的前进是靠数据的时间戳来驱动的。但在分布式系统中，这种驱动方式又会有一些问题。因为数据本身在处理转换的过程中会变化 ...

要想说清楚Flink水位线（WaterMark），前提需要弄清楚几个概念。 第一个是时间概念： 在Flink中有三个时间概念，分别是事件时间，采集时间，和系统时间。 事件时间：在客观世界中产生的时间，比如用户点击网页产生了一条时间日志，这个时间就是事件时间。 采集时间：我们用Flink采集 ...

主要介绍 Flink 中的时间和水印。 我们在之前的课时中反复提到过窗口和时间的概念，Flink 框架中支持事件时间、摄入时间和处理时间三种。而当我们在流式计算环境中数据从 Source 产生，再到转换和输出，这个过程由于网络和反压的原因会导致消息乱序。因此，需要有一个机制来解决 ...

相关文章链接 Flink之Window的使用（1）：计数窗口 Flink之Window的使用（2）：时间窗口 Flink之Window的使用（3）：WindowFunction的使用 具体实现代码如下所示： ...

Flink流处理的时间窗口 对于流处理系统来说，流入的消息是无限的，所以对于聚合或是连接等操作，流处理系统需要对流入的消息进行分段，然后基于每一段数据进行聚合或是连接等操作。 消息的分段即称为窗口，流处理系统支持的窗口有很多类型，最常见的就是时间窗口，基于时间间隔对消息进行分段处理。本节主要 ...

　　使用flink-1.9.0进行的测试，在不同的并行度下，Flink对事件时间的处理逻辑不同。包括1.1在并行度为1的本地模式分析和1.2在多并行度的本地模式分析两部分。通过理论结合源码进行验证，得到具有说服力的结论。 一、使用并行度为1的本地模式测试 1.1、Flink时间时间窗口 ...