[SAMZA-652] A time-based window operator for join

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: sql
• Assignee: Unassigned
• Reporter: Yi Pan
• Created: 15/Apr/15 23:46
• Updated: 15/Apr/15 23:53

Description

This is the first version of window operator that support the following join use case:

SELECT STREAM a.time as time, a.id as id, a.a, b.b FROM A as a JOIN B as b ON  a.id = b.id AND a.time > b.time - 3 MIN AND a.time < b.time + 5 MIN

Hence, the window operator here is a time-based, fixed-length window for a inner join. It will need to have window metadata and message stores to allow join to access the messages in the past windows.