[BEAM-4090] Fork/Update Primitive Implementations for the ReferenceRunner

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: runner-direct
• Labels: portability
• Assignee: Thomas Groh
• Reporter: Thomas Groh
• Created: 16/Apr/18 18:31
• Updated: 16/May/20 13:37
• Resolved: 01/Jun/18 18:18

Description

The primitives that require implementation are:

Impulse, Flatten, GroupByKey

GroupByKey may be implemented by PartitionByKey/GroupByKeyAndWindow 

The primitives that may be implemented as well are:

AssignWindows, for known WindowFns

Issue Links

• links to: GitHub Pull Request #5194