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)