You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2015/04/16 01:53:58 UTC
[jira] [Updated] (SAMZA-652) A time-based window operator for join
[ https://issues.apache.org/jira/browse/SAMZA-652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yi Pan (Data Infrastructure) updated SAMZA-652:
-----------------------------------------------
Description:
This is the first version of window operator that support the following join use case:
{code}
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
{code}
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.
was:
This is the first version of window operator that support the following join use case:
{code}
SELECT 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
{code}
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.
> A time-based window operator for join
> -------------------------------------
>
> Key: SAMZA-652
> URL: https://issues.apache.org/jira/browse/SAMZA-652
> Project: Samza
> Issue Type: Sub-task
> Components: sql
> Reporter: Yi Pan (Data Infrastructure)
>
> This is the first version of window operator that support the following join use case:
> {code}
> 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
> {code}
> 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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)