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.