apache_beam.testing.benchmarks.nexmark.queries.query0 module

Nexmark Query 0: Pass through (send and receive auction events).

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

This query is a pass through that simply parses the events generated by the launcher. It serves as a test to verify the infrastructure.

apache_beam.testing.benchmarks.nexmark.queries.query0.load(raw_events, query_args=None)[source]