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

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

Jagadish created SAMZA-1473:
-------------------------------

             Summary: 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)