[
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)
