[BEAM-2855] Implement a Python version of the Nexmark queries

• Type: Sub-task
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: Missing
• Component/s: sdk-py-core, testing, testing-nexmark
• Labels: newbie nexmark starter
• Assignee: Yichi Zhang
• Reporter: Ismaël Mejía
• Created: 06/Sep/17 16:24
• Updated: 13/Jan/22 21:52
• Resolved: 23/Sep/21 22:08

Description

Currently we have a Java only implementation of Nexmark, a python based implementation would be nice to have to validate the direct and dataflow runners, but also to validate the new support of multiple SDKs in multiple runners via the runner/fn API.

Issue Links

• blocks: BEAM-8261 Run Nexmark Python based queries on Spark portable runner
• blocks: BEAM-8262 Run Nexmark Python based queries on Flink portable runner
• duplicates: BEAM-9904 python nexmark query pipelines
• links to: GitHub Pull Request #5738
• links to: GitHub Pull Request #5837
• links to: GitHub Pull Request #12427
• links to: GitHub Pull Request #12580
• links to: GitHub Pull Request #12675
• links to: GitHub Pull Request #12807