You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
We'd like to support joins between a windowed aggregate and a non-windowed stream. This would allow us to run Nexmark Query 6. The Arroyo version of the query is below. Ideally we'd also inspect the WHERE clause in order to not keep data around after the window has passed, as the only data from B1 we care about is that within active windows.
WITH
auction as (
SELECT auction.category as category,
auction.datetime as datetime,
auction.expires as expires,
auction.id as id
FROM nexmark where auction is not null),
bid as (
SELECT bid.auction as auction,
bid.bidder as bidder,
bid.extra as extra,
bid.datetime as datetime,
bid.price as price
FROM nexmark where bid is not null)
SELECT B.auction, B.price, B.bidder, B.dateTime, B.extra
from bid B
JOIN (
SELECT MAX(B1.price) AS maxprice, tumble(INTERVAL '10' SECOND) as window
FROM bid B1
GROUP BY 2
) B1
ON B.price = B1.maxprice
WHERE B.dateTime BETWEEN B1.window.start_time AND B1.window.end_time;
The text was updated successfully, but these errors were encountered:
We'd like to support joins between a windowed aggregate and a non-windowed stream. This would allow us to run Nexmark Query 6. The Arroyo version of the query is below. Ideally we'd also inspect the WHERE clause in order to not keep data around after the window has passed, as the only data from B1 we care about is that within active windows.
The text was updated successfully, but these errors were encountered: