[BEAM-9937] Support TestStream in Spark Runner

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-spark
• Assignee: Unassigned
• Reporter: Ismaël Mejía
• Created: 08/May/20 23:47
• Updated: 04/Jun/22 15:36

Description

The Classic Spark Runner includes a class called CreateStream that precedes functionally TestStream. The idea would be to replace it with TestStream with a real translation as a way to run TestStream based tests on the Spark runner.