apache_beam.testing.benchmarks.nexmark.queries.query12 module

Query 12, How many bids does a user make within a fixed processing time limit (Not in original suite.)

Group bids by the same user into processing time windows of window_size_sec. Emit the count of bids per window.

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