Hey, Julian,
Thanks! I was head-down in writing out the design doc for the window
operator till now.
Thanks for your explanation. I think that we have an agreement on this now.
If we interpret Q.2 and Q.3 equivalent, there is an implicit assumption in
Q.2 that Orders.rowtime = Shipment.rowtime, w
See answers inline. Proving, yet again, that there's no such thing as a short
semantics email. :)
> On Mar 9, 2015, at 12:48 PM, Yi Pan wrote:
>
> Hi, Julian,
>
> Thanks for the reply. I want to make sure that I understand your
> explanation on windows in JOIN more explicitly.
> For the follow
Hi, Julian,
Thanks for the reply. I want to make sure that I understand your
explanation on windows in JOIN more explicitly.
For the following case:
Q.1) SELECT STREAM id, cost, value, Shipments.rowtime as shiptime FROM
Orders OVER (ORDER BY rowtime RANGE '3' min PROCEDING)
JOIN Shipments OVER
First of all, if you want a stream output, you should add the 'STREAM'
keyword after 'SELECT'.
There isn't quite enough information to make the query well-defined. I
need to assume that each stream has an increasing rowtime column, and
that the "OVER (ROWS 3 PRECEDING)" windows on each stream are
