[BEAM-3859] Add an override to read from an Unbounded Source via Impulse and ParDo

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-core
• Assignee: Unassigned
• Reporter: Thomas Groh
• Created: 15/Mar/18 18:55
• Updated: 03/Jun/22 21:06

Description

This enables more movement towards BEAM-2421.

 

The DoFn that implements an UnboundedRead will have to be performed by a Splittable DoFn, as otherwise a reader can (and likely will) produce unbounded output per split, and cannot properly hold watermarks.