search

flock-lab / flock

Flock: A Low-Cost Streaming Query Engine on FaaS Platforms
https://flock-lab.github.io/flock/
GNU Affero General Public License v3.0
291 stars 39 forks source link

feat!: support nexmark q11 in local #381

Closed gangliao closed 2 years ago

gangliao commented 2 years ago

Which issue does this PR close?

Closes #.

Rationale for this change

What changes are included in this PR?

Are there any user-facing changes?

By submitting this pull request

gangliao commented 2 years ago 
running 1 test
New Session Window
New Session Window
+--------+-----------+-------------------------+-------------------------+
| bidder | bid_count | starttime               | endtime                 |
+--------+-----------+-------------------------+-------------------------+
| 1002   | 4         | 2015-07-15 00:00:00.240 | 2015-07-15 00:00:02.660 |
| 1014   | 1         | 2015-07-15 00:00:04.360 | 2015-07-15 00:00:04.360 |
+--------+-----------+-------------------------+-------------------------+
New Session Window
New Session Window
+--------+-----------+-------------------------+-------------------------+
| bidder | bid_count | starttime               | endtime                 |
+--------+-----------+-------------------------+-------------------------+
| 1005   | 8         | 2015-07-15 00:00:01.240 | 2015-07-15 00:00:05.580 |
| 1003   | 10        | 2015-07-15 00:00:00.180 | 2015-07-15 00:00:06.360 |
+--------+-----------+-------------------------+-------------------------+
New Session Window
+--------+-----------+-------------------------+-------------------------+
| bidder | bid_count | starttime               | endtime                 |
+--------+-----------+-------------------------+-------------------------+
| 1020   | 1         | 2015-07-15 00:00:10.220 | 2015-07-15 00:00:10.220 |
+--------+-----------+-------------------------+-------------------------+
New Session Window
New Session Window
+--------+-----------+-------------------------+-------------------------+
| bidder | bid_count | starttime               | endtime                 |
+--------+-----------+-------------------------+-------------------------+
| 1012   | 8         | 2015-07-15 00:00:04.140 | 2015-07-15 00:00:12.720 |
| 1013   | 12        | 2015-07-15 00:00:04.880 | 2015-07-15 00:00:12.320 |
+--------+-----------+-------------------------+-------------------------+
New Session Window
New Session Window
+--------+-----------+-------------------------+-------------------------+
| bidder | bid_count | starttime               | endtime                 |
+--------+-----------+-------------------------+-------------------------+
| 1008   | 6         | 2015-07-15 00:00:00.440 | 2015-07-15 00:00:13.580 |
| 1018   | 2         | 2015-07-15 00:00:09.360 | 2015-07-15 00:00:11.580 |
+--------+-----------+-------------------------+-------------------------+
New Session Window
+--------+-----------+-------------------------+-------------------------+
| bidder | bid_count | starttime               | endtime                 |
+--------+-----------+-------------------------+-------------------------+
| 1006   | 10        | 2015-07-15 00:00:00.640 | 2015-07-15 00:00:14.280 |
+--------+-----------+-------------------------+-------------------------+
test datasource::nexmark::queries::q11::tests::local_query_11 ... ok
gangliao commented 2 years ago

This query is very complicated. We need to group bids by the same user into sessions with session intervals (10 seconds).