flink实战—Watermarks的原理和应用

概述 本文介绍flink的一个重要特性：水印(Watermarks)的原理，并经过实际的例子说明如何使用该特性。 环境：flink-1.7.1html 水印(Watermarks)简介 咱们看到对事件时间(Event Time)的支持是流体系结构的核心。当计算基于事件时间时，咱们如何知道全部事件是否已经所有到达，咱们是否能够计算并输出窗口的结果？换句话说，咱们如何跟踪事件时间并知道输入流中已达到某

>>阅读原文<<