[BEAM-3127] Portable flattens in Dataflow Runner

• Type: Sub-task
• Status: Resolved
• Priority: P2
• Resolution: Done
• Fix Version/s: Not applicable
• Component/s: runner-dataflow
• Assignee: Daniel Oliveira
• Reporter: Daniel Oliveira
• Created: 31/Oct/17 18:19
• Updated: 16/May/20 13:58
• Resolved: 12/Mar/18 21:13

Description

Get flattens working with portability in the Dataflow Runner. Currently flattens are removed from execution and the PCollections received by the flatten are instead sent to the DoFns that consume the flatten. This behavior should be removed; Flattens should remain in the graph so that DoFns always have one input.