[jira] [Created] (SAMZA-1386) Inline End-of-stream and Watermark logic inside OperatorImpl

[Xinyu Liu (JIRA)]

Xinyu Liu created SAMZA-1386:
--------------------------------

             Summary: Inline End-of-stream and Watermark logic inside 
OperatorImpl
                 Key: SAMZA-1386
                 URL: https://issues.apache.org/jira/browse/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
(v6.4.14#64029)