Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1982

Use TimerRegistry to track time based window triggers instead of relying on window()

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • 1.1
    • None
    • None

    Description

      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.

      Attachments

        Activity

          People

            bharathkk Bharath Kumarasubramanian
            pmaheshwari Prateek Maheshwari
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: