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)

Reply via email to