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

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: 1.1
    • Component/s: None
    • Labels:
      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

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

              Dates

              • Created:
                Updated: