Details
-
Sub-task
-
Status: Resolved
-
P2
-
Resolution: Abandoned
-
None
-
None
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 |
Attachments
Issue Links
- is duplicated by
-
-
- Resolved
-