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.).
load(events, metadata=None, pipeline_options=None)¶