apache_beam.testing.benchmarks.nexmark.queries.query7 module

Query 7, ‘Highest Bid’. Select the bids with the highest bid price in the last minute. In CQL syntax:

SELECT Rstream(B.auction, B.price, B.bidder)
FROM Bid [RANGE 1 MINUTE SLIDE 1 MINUTE] B
WHERE B.price = (SELECT MAX(B1.price)
                 FROM BID [RANGE 1 MINUTE SLIDE 1 MINUTE] B1);

We will use a shorter window to help make testing easier. We’ll also implement this using a side-input in order to exercise that functionality. (A combiner, as used in Query 5, is a more efficient approach.).

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

class apache_beam.testing.benchmarks.nexmark.queries.query7.SelectMaxBidFn(*unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element, max_bid_price)