[BEAM-2421] Migrate Apache Beam to use impulse primitive as the only root primitive

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Works for Me
• Fix Version/s: Not applicable
• Component/s: beam-model
• Labels: portability
• Assignee: Luke Cwik
• Reporter: Luke Cwik
• Created: 07/Jun/17 15:16
• Updated: 16/May/20 14:10
• Resolved: 22/Apr/20 20:53

Description

The impulse source emits a single byte array element within the global window.

This is in preparation for using SDF as the replacement for different bounded and unbounded source implementations.

Before:
Read(Source) -> ParDo -> ...
Impulse -> SDF(Source) -> ParDo -> ...

Issue Links

• is depended upon by: BEAM-2889 Flink runs portable pipelines
• links to: GitHub Pull Request #3312
• links to: GitHub Pull Request #3349
• links to: GitHub Pull Request #4234
• links to: GitHub Pull Request #4717
• links to: GitHub Pull Request #4776