calcite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Haohui Mai <whe...@apache.org>
Subject Expressing windowed stream-stream joins in SQL
Date Fri, 24 Feb 2017 22:32:57 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message