[NEMO-229] Support watermark

• Type: Umbrella
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.1
• Labels: runtime
• Assignee: Unassigned
• Reporter: Tae-Geon Um
• Created: 23/Oct/18 07:08
• Updated: 25/Nov/18 23:39
• Resolved: 25/Nov/18 23:39

Description

To fully support streaming on Nemo, we should support watermark.

Issue Links

• is a child of: NEMO-157 Support Nemo Streaming
• is a parent of: NEMO-247 UnboundedSource WindowedWordCount ITCase
• is a parent of: NEMO-230 Emit collected data when receiving watermark in GroupByKeyAndWindowTransform
• is a parent of: NEMO-231 Add onWatermark() method to Transform
• is a parent of: NEMO-232 Implement InputWatermarkManager
• is a parent of: NEMO-233 Emit watermark at unbounded source
• is a parent of: NEMO-237 Refactor ParentTaskDataFetcher to emit streaming data and watermark
• is a parent of: NEMO-245 Handle watermark in OutputWriter
• relates to: NEMO-235 Refactor TaskExecutor's data processing logic
• relates to: NEMO-216 Support side inputs and windowing