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

Question

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

需要窗口化的示例查询 SELECT sourceKafka.* FROM sourceKafka INNER JOIN badips ON sourceKafka。source.ip=badips.ip

sourceKafka 是源表，连续不断的 kafka badips 流是另一个源表

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

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