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

Query 2: Find bids with specific auction ids and show their bid price

This query selects Bids that have a particular auctiuon id, and output their auction id with bid price. It illustrates a simple filter.

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