apache_beam.testing.benchmarks.nexmark.queries.query1 module

Nexmark Query 1: Convert bid prices from dollars to euros.

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

This query converts bid prices from dollars to euros. It illustrates a simple map.

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