[NEMO-157] Support Nemo Streaming

• Type: Umbrella
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.2
• Assignee: Unassigned
• Reporter: Jeongyoon Eo
• Created: 12/Jul/18 08:25
• Updated: 07/Mar/20 06:48
• Resolved: 11/Mar/19 08:49

Description

Currently Nemo supports batch data processing only. We're planning to support stream execution mode in Nemo.

Issue Links

• incorporates: NEMO-129 Support Beam's WindowedWordCount example
• is a parent of: NEMO-224 Simple StreamingScheduler
• is a parent of: NEMO-128 Support Beam UnBoundedSource
• is a parent of: NEMO-237 Refactor ParentTaskDataFetcher to emit streaming data and watermark
• is a parent of: NEMO-216 Support side inputs and windowing
• is a parent of: NEMO-229 Support watermark
• relates to: NEMO-282 Handle late data
• relates to: NEMO-213 Use Beam's DoFnRunners to execute DoFn