Query 8, ‘Monitor New Users’. Select people who have entered the system and created auctions in the last 12 hours, updated every 12 hours. In CQL syntax:
SELECT Rstream(P.id, P.name, A.reserve) FROM Person [RANGE 12 HOUR] P, Auction [RANGE 12 HOUR] A WHERE P.id = A.seller;
To make things a bit more dynamic and easier to test we’ll use a much shorter window.
load(events, metadata=None, pipeline_options=None)¶