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

Allow user WatermarkFunction to exclude streams from Watermark computation

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Won't Fix
    • 0.15.0
    • 0.15.0
    • None
    • None

    Description

      Current watermark logic calculates the watermark based on the watermark from all the upstream operators. BEAM has a very special use case that requires excluding certain streams from this calcuation (view streams), and the watermark from these streams should be directly passed down to the WatermarkFunction.

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: