| Actor | Fragment | Worker | State |
|---|---|---|---|
| 99282 | 2483 | 26 | running |
| 99283 | 2483 | 26 | running |
| 99296 | 2484 | 26 | running |
| 99297 | 2484 | 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