| Actor | Fragment | Worker | State |
|---|---|---|---|
| 54114 | 2483 | 3 | running |
| 54115 | 2483 | 3 | running |
| 54154 | 2484 | 3 | running |
| 54155 | 2484 | 3 | running |
CREATE MATERIALIZED VIEW insights.intraday_asset_prices_5min_mv AS
SELECT
window_start,
asset_id,
(
ARRAY_AGG(last ORDER BY value_timestamp DESC, as_of_timestamp DESC)
)[1] AS last_price,
MAX(value_timestamp) AS value_timestamp
FROM TUMBLE(asset_service.intraday_asset_prices_ft, value_timestamp, INTERVAL '5 MINUTES')
GROUP BY
window_start,
asset_id EMIT ON WINDOW CLOSE