[SAMZA-1386] Inline End-of-stream and Watermark logic inside OperatorImpl

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.14.0
• Fix Version/s: 0.14.0
• Assignee: Xinyu Liu
• Reporter: Xinyu Liu
• Created: 09/Aug/17 23:49
• Updated: 21/Nov/17 19:31
• Resolved: 21/Nov/17 19:30

Description

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.

Issue Links

• links to: GitHub Pull Request #277