©2016-2024 Matools All rights reserved,
粤ICP备17059708号
说什么
JOIN 算子是数据处理的核心算子，前面我们在《Apache Flink 漫谈系列(09) - JOIN
算子》介绍了UnBounded的双流JOIN，在《Apache Flink 漫谈系列(10) - JOIN
LATERAL》介绍了单流与UDTF的JOIN操作，在《Apache Flink 漫谈系列(11) - Temporal Table
JOIN》又介绍了单流与版本表的JOIN，本篇将介绍在UnBounded数据流上按时间维度进行数据划分进行JOIN操作 - Time
Interval(Time-windowed)JOIN, 后面我们叫做Interval JOIN。
实际问题
前面章节我们介绍了Flink中对各种JOIN的支持，那么想想下面的查询需求之前介绍的JOIN能否满足？需求描述如下:
比如有一个订单表Orders(
热门工具 换一换