[
https://issues.apache.org/jira/browse/SAMZA-650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14527325#comment-14527325
]
Yi Pan (Data Infrastructure) commented on SAMZA-650:
----------------------------------------------------
Sure. Forgot to link it. Here is the RB: https://reviews.apache.org/r/33749/
Thanks!
> 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)
