Apache Flink 漫談系列(12) - Time Interval(Time-windowed) JOIN

說什么

JOIN 算子是數(shù)據(jù)處理的核心算子，前面我們在《Apache Flink 漫談系列(09) - JOIN
算子》介紹了UnBounded的雙流JOIN，在《Apache Flink 漫談系列(10) - JOIN
LATERAL》介紹了單流與UDTF的JOIN操作，在《Apache Flink 漫談系列(11) - Temporal Table
JOIN》又介紹了單流與版本表的JOIN，本篇將介紹在UnBounded數(shù)據(jù)流上按時間維度進(jìn)行數(shù)據(jù)劃分進(jìn)行JOIN操作 - Time
Interval(Time-windowed)JOIN, 后面我們叫做Interval JOIN。

實際問題

前面章節(jié)我們介紹了Flink中對各種JOIN的支持，那么想想下面的查詢需求之前介紹的JOIN能否滿足？需求描述如下:

比如有一個訂單表Orders(

• ? 上一篇： 2.0 解析系列 | OceanBase負(fù)載均衡的魅力
• ? 下一篇： Tableau BI工具對接 AnalyticDB for PostgreSQL數(shù)據(jù)源