[jira] [Closed] (SAMZA-1473) Fix handling of initial values in windows with aggregating functions

["Jagadish (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jagadish closed SAMZA-1473.
---------------------------

> Fix handling of initial values in windows with aggregating functions
> --------------------------------------------------------------------
>
>                 Key: SAMZA-1473
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1473
>             Project: Samza
>          Issue Type: Sub-task
>            Reporter: Jagadish
>
> Currently, we assert that tumbling windows that have a FoldLeftFunction configured should only have exactly one message in their window-panes. However, this is not true during window initialization (when the windowpane is first constructed and the store does not contain any previous state for the window.)
> The correct check should be as follows:
> {code}
>       Object oldVal = existingState.size() == 0 ? initializer.get() : existingState.get(0);
> {code}
> If there is no state, we'll use the initial state. If there is previous state, we'll use its value.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)