apache_beam.testing.benchmarks.nexmark.queries.query8 module¶
Query 8, ‘Monitor New Users’. Select people who have entered the system and created auctions in the last 12 hours, updated every 12 hours. In CQL syntax:
SELECT Rstream(P.id, P.name, A.reserve)
FROM Person [RANGE 12 HOUR] P, Auction [RANGE 12 HOUR] A
WHERE P.id = A.seller;
To make things a bit more dynamic and easier to test we’ll use a much shorter window.