| Actor | Fragment | Worker | State |
|---|---|---|---|
| 97106 | 5399 | 26 | running |
| 97107 | 5399 | 26 | running |
| 97261 | 5400 | 26 | running |
| 97262 | 5400 | 26 | 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