[BEAM-9904] python nexmark query pipelines

• Type: Sub-task
• Status: Resolved
• Priority: P2
• Resolution: Abandoned
• Fix Version/s: Not applicable
• Component/s: benchmarking-py, testing-nexmark
• Assignee: Unassigned
• Reporter: Yichi Zhang
• Created: 06/May/20 17:06
• Updated: 24/Jul/20 19:53
• Resolved: 07/May/20 16:35

Description

Create python beam pipelines for the data analytic queries in NexMark suite:

 

query	corresponding java code
Query 0 (not part of original NexMark): Pass-through.	query0.java
Query 1: What are the bid values in Euro's? (Currency Conversion)	query1.java
Query 2: Find bids with specific auction ids and show their bid price.	query2.java
Query 3: Who is selling in particular US states?	query3.java
Query 4: What is the average selling price for each auction category?	query4.java
Query 5: Which auctions have seen the most bids in the last period?	query5.java

 

Issue Links

• is duplicated by: BEAM-2855 Implement a Python version of the Nexmark queries