apache_beam.testing.benchmarks.nexmark.queries.query2 module

Nexmark Query 2: Select auctions by auction id.

The Nexmark suite is a series of queries (streaming pipelines) performed on a simulation of auction events.

This query selects auctions (items) that have a particular id. It illustrates a simple filter.

apache_beam.testing.benchmarks.nexmark.queries.query2.load(raw_events, metadata=None)