Hi, Julian,
Thanks for the example. Could you also comment on how can user specifies
the "timeout" to terminate the window in my example? I.e. there is no rows
delivered in 5min, close the current window? Essentially, how do user
specify "punctuation point" in the stream w/o breaking SQL planner?
The answer depends on your design philosophy. We need to strike a balance
between making it possible and making it easy. Because SQL is a powerful closed
language, we can achieve a lot by combining the elements. For example, I think
that your example can be solved by joining a "heartbeat" stream
