[ 
https://issues.apache.org/jira/browse/SAMZA-650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14527316#comment-14527316
 ] 

Guozhang Wang commented on SAMZA-650:
-------------------------------------

[~nickpan47] Could you add the RB link for this ticket for reviews?

> Implement window metadata store
> -------------------------------
>
>                 Key: SAMZA-650
>                 URL: https://issues.apache.org/jira/browse/SAMZA-650
>             Project: Samza
>          Issue Type: Sub-task
>          Components: sql
>            Reporter: Yi Pan (Data Infrastructure)
>            Assignee: Yi Pan (Data Infrastructure)
>
> In SAMZA-552, window operator is designed to have a window metadata store 
> internally to keep all windows' metadata in retention. This metadata store 
> should be a KV store w/ a changelog (i.e. LoggedStore), with the following 
> definition of key and value:
> # Time-based window metadata store:
> ## Key: window start timestamp
> ## Value: {start_time, start_offset, end_time, last_offset}
> # Tuple-based window metadata store:
> ## Key: window start offset
> ## Value: {start_offset, last_offset}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to