[ 
https://issues.apache.org/jira/browse/SAMZA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16890454#comment-16890454
 ] 

Bharath Kumarasubramanian commented on SAMZA-1982:
--------------------------------------------------

I am not working on this actively. Will try to get this in for our next release 
1.3

> Use TimerRegistry to track time based window triggers instead of relying on 
> window()
> ------------------------------------------------------------------------------------
>
>                 Key: SAMZA-1982
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1982
>             Project: Samza
>          Issue Type: Improvement
>            Reporter: Prateek Maheshwari
>            Assignee: Bharath Kumarasubramanian
>            Priority: Major
>             Fix For: 1.1
>
>
> Now that we have support for arbitrary processing time timer callbacks 
> (TimerRegistry), we can switch from window() call based triggers to using 
> more precise triggers. Currently we set the window interval to be the GCD of 
> all window intervals. This has the disadvantage of keeping session windows 
> open longer than necessary, since in the worst case a new message has up to 2 
> * window time to arrive.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to