A question regarding to the default semantic meaning of join

2015-03-06 Thread Yi Pan
Hi, Julian, I am writing down some detailed examples of join and need your further help in understanding the semantic meaning of the following example: SELECT id, value, cost FROM Orders OVER (ROWS 3 PRECEDING) JOIN Shipments OVER (ROWS 3 PROCEDING) ON Orders.id = Shipments.id In this example,

Re: Handling defaults and windowed aggregates in stream queries

2015-03-06 Thread Milinda Pathirage
I think my previous comment about maintaining start and end offsets as the window state will not work when there are delays. We may need to keep multiple such offsets. But this may not be a clean solution. On Thu, Mar 5, 2015 at 2:42 PM, Milinda Pathirage mpath...@umail.iu.edu wrote: Hi Yi,

Re: Handling defaults and windowed aggregates in stream queries

2015-03-06 Thread Yi Pan
Hi, Milinda, Let me put my answers below: On Thu, Mar 5, 2015 at 11:42 AM, Milinda Pathirage mpath...@umail.iu.edu wrote: a) Each window will have a closing policy: it would either be wall-clock based timeout, or the arrival of messages indicating that we have received all messages in

Re: Review Request 31718: Samza 465 [Draft]

2015-03-06 Thread Naveen Somasundaram
On March 6, 2015, 5:12 p.m., Chris Riccomini wrote: We should definitely open a follow-on JIRA to convert Util to Java, and remove UtilJ. I can't find UtilJ file. CheckpointManager seems to be deleted. This RB seems broken. Overall, looks good. Will need to see the rest of the