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)