Hi, I wonder what would be the best way to express joining two windowed streams in SQL?
A even simpler use case will be joining two streams within the same window (see https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html). I'm looking at something like SELECT a.foo, b.bar FROM a JOIN a.id = b.id GROUP BY TUMBLE(a. rowtime, INTERVAL '1' MINUTE) Is it the right syntax? Or on a even higher level, does this query has proper semantics? Your comments are appreciated. Regards, Haohui