apache_beam.testing.benchmarks.nexmark.queries.query9 module
Query 9: Winning-bids: extract the most recent of the highest bids
See winning_bids.py for detailed documentation
-
apache_beam.testing.benchmarks.nexmark.queries.query9.
load
(events, metadata=None, pipeline_options=None)[source]