apache_beam.testing.benchmarks.nexmark.queries.query11 module

Query 11, How many bids did a user make in each session he was active? (Not in original suite.)

Group bids by the same user into sessions with window_size_sec max gap. However limit the session to at most max_log_events. Emit the number of bids per session.

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