How do we window join using SQL client in Flink SQL query?

Question

How do we window join using SQL client in Flink SQL query. Windowing in the same fashion as mention in link below https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/operators/joining.html

Sample Query that requires windowing SELECT sourceKafka.* FROM sourceKafka INNER JOIN badips ON sourceKafka.source.ip=badips.ip

sourceKafka is source-table, with continuous stream of kafka badips is another source-table

David Anderson · Accepted Answer · 2019-09-16 19:22:03Z

1

Here's an example of a time windowed join, using 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

See the docs for more details.

answered Sep 16, 2019 at 19:22

David Anderson

44.3k4 gold badges41 silver badges73 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Then, How to write tumbling/sliding/session window join using Flink SQL? see ci.apache.org/projects/flink/flink-docs-stable/dev/stream/…