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

Pass in typed control message into EndOfStreamManager.update() and WatermarkManager.update()

    XMLWordPrintableJSON

Details

    • Task
    • Status: Resolved
    • Major
    • Resolution: Duplicate
    • 0.14.0
    • 0.14.0
    • None
    • None

    Description

      From Yi's review feedback: Right now EndOfStreamManager.update() and WatermarkManager.update() takes in IncomingMessageEnvelope. It's better to pass in typed control message and ssp to it to avoid type cast.

      Attachments

        Issue Links

          is depended upon by

          New Feature - A new feature of the product, which has yet to be developed. SAMZA-1260 Support Control Messages Across Intermediate Streams

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              xinyu Xinyu Liu
              xinyu Xinyu Liu
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: