我们如何在 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是source-table，连续的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

有关详细信息，请参阅docs。