Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
@pentium3
pentium3 authored Sep 3, 2024
1 parent 18bf012 commit f7ae9e6
Showing 1 changed file with 0 additions and 32 deletions.
32 changes: 0 additions & 32 deletions queries/nexmark/README.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,38 +13,6 @@ https://github.com/apache/beam/blob/master/sdks/java/testing/nexmark/src/main/ja

## Queries

see https://github.com/pentium3/sys_reading/issues/73#issuecomment-930817091

### Query1: map + filter + sink

Input parameter: event generating rate. ```--ratelist [<rate>_<duration>]^n```

e.g. ```--ratelist 250_300000_11000_300000```

### Query3: a stateful record-at-a-time two-input operator (incremental join)

contains 2 sources: auctions and persons

![image](https://user-images.githubusercontent.com/7352163/144359118-dd0fd056-d270-4c54-b8fc-40adba3539c7.png)

Input parameter: event generating rate. ```--ratelist [<auctions_rate>_<duration>_<persons_rate>_<duration> ]^n```

e.g. ```--ratelist 50000_300000_10000_300000_1000_600000_200_600000```

### Query5: sliding window

![image](https://user-images.githubusercontent.com/7352163/144932007-2109feff-f978-4b04-a811-08ccb121547c.png)

Input parameter: event generating rate. ```--ratelist [<rate>_<duration> ]^n```

e.g. ```--ratelist 250_300000_11000_300000```

### Query8: tumbling window join

![image](https://user-images.githubusercontent.com/7352163/144933551-a0582476-9cbd-410c-8265-4b0e9d6946d3.png)

Input parameter: event generating rate. ```--ratelist [<auctions_rate>_<duration>_<persons_rate>_<duration> ]^n```

e.g. ```--ratelist 50000_300000_10000_300000_1000_600000_200_600000```


0 comments on commit f7ae9e6

Please sign in to comment.