我们如何在 Flink SQL 查询中使用 SQL 客户端进行窗口连接?

Question

我们如何在 Flink SQL 查询中使用 SQL 客户端进行窗口连接。 窗口化方式与下面链接中提到的相同 https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/operators/joining.html

需要窗口化的示例查询 选择来源卡夫卡。 从来源卡夫卡内联接巴迪普斯在源卡夫卡。source.ip=badips.ip

源卡夫卡是源表，具有连续的卡夫卡流 巴迪普斯是另一个源表

Answer 1

下面是一个使用 Flink SQL 的时间窗口连接示例：

SELECT *
FROM Orders o, Shipments s
WHERE o.id = s.orderId AND
o.ordertime BETWEEN s.shiptime - INTERVAL '4' HOUR AND s.shiptime

有关更多详细信息，请参阅文档。