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.

apache_beam.testing.benchmarks.nexmark.queries.query8.load(events, metadata=None, pipeline_options=None)

class apache_beam.testing.benchmarks.nexmark.queries.query8.JoinPersonAuctionFn(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element)