Flink的Interval Join是基于水印（Watermark）和时间窗口（Time Window）实现的。水印是用来检测和处理乱序事件的一种机制，它可以用来估计事件的最大延迟时间。在Flink中，每个事件都会被分配一个时间戳，这个时间戳表示事件发生的时间。当水印的值大于或等于一个事件的时间戳时，Flink就会认为这个事件已经到达，可以进行处理。
Interval Join的工作原理是，它会检查在一个时间窗口内，一个事件是否与另一个事件的时间戳在一个指定的区间内。这个时间窗口是由水印和事件的时间戳决定的。例如，如果你设置了一个5分钟的时间窗口，那么Interval Join就会检查在当前水印的前5分钟内，一个事件的时间戳是否在另一个事件的时间戳的前5分钟内。
所以，虽然Interval Join是基于水印和时间窗口实现的，但是它仍然依赖于事件的时间戳。事件的时间戳决定了哪些事件会在一个特定的水印时被处理，以及哪些事件会被包含在一个特定的时间窗口内。Flink的Interval Join是基于水印（Watermark）和时间窗口（Time Window）实现的。水印是用来检测和处理乱序事件的一种机制，它可以用来估计事件的最大延迟时间。在Flink中，每个事件都会被分配一个时间戳，这个时间戳表示事件发生的时间。当水印的值大于或等于一个事件的时间戳时，Flink就会认为这个事件已经到达，可以进行处理。
Interval Join的工作原理是，它会检查在一个时间窗口内，一个事件是否与另一个事件的时间戳在一个指定的区间内。这个时间窗口是由水印和事件的时间戳决定的。例如，如果你设置了一个5分钟的时间窗口，那么Interval Join就会检查在当前水印的前5分钟内，一个事件的时间戳是否在另一个事件的时间戳的前5分钟内。
所以，虽然Interval Join是基于水印和时间窗口实现的，但是它仍然依赖于事件的时间戳。事件的时间戳决定了哪些事件会在一个特定的水印时被处理，以及哪些事件会被包含在一个特定的时间窗口内。
