Xinyu Liu created SAMZA-1386:

             Summary: Inline End-of-stream and Watermark logic inside 
                 Key: SAMZA-1386
             Project: Samza
          Issue Type: Bug
    Affects Versions: 0.14.0
            Reporter: Xinyu Liu
            Assignee: Xinyu Liu

Currently both EOS and Watermark aggregation/population logic is inside 
TaskInstance. Since watermark handling logic is in OperatorImpl, it makes sense 
to consolidate them together inside OperatorImpl, and make it feasible to 
provide user API to emit watermarks.

This message was sent by Atlassian JIRA

Reply via email to