You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Jagadish (JIRA)" <ji...@apache.org> on 2017/07/13 22:18:00 UTC

[jira] [Created] (SAMZA-1362) Revisit window APIs in Samza

Jagadish created SAMZA-1362:
-------------------------------

             Summary: Revisit window APIs in Samza
                 Key: SAMZA-1362
                 URL: https://issues.apache.org/jira/browse/SAMZA-1362
             Project: Samza
          Issue Type: Bug
            Reporter: Jagadish


Currently, there is a combinatorial number of parameters to the window API. Specifically, we allow
- keyed vs non-keyed windows
- event time vs processing time windows
- session vs tumbling windows
- aggregated vs non-aggregated

On top of each, we have additional parameters for specifying serdes. 

We should re-visit how we specify different window types. A couple of ideas include:
- Having a builder style API for window construction
- Having a Flink / Kafka streams like API that splits aggregation from the actual window specification



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