| Actor | Fragment | Worker | State |
|---|---|---|---|
| 97114 | 5384 | 26 | running |
| 97115 | 5384 | 26 | running |
| 97116 | 5385 | 26 | running |
| 97117 | 5385 | 26 | running |
CREATE MATERIALIZED VIEW insights.intraday_fx_rates_5min_mv AS
SELECT
window_start,
source_currency_code,
target_currency_code,
(
ARRAY_AGG(rate ORDER BY value_timestamp DESC, as_of_timestamp DESC)
)[1] AS rate,
MAX(value_timestamp) AS value_timestamp
FROM TUMBLE(
asset_service.intraday_foreign_exchange_rates_ft,
value_timestamp,
INTERVAL '5 MINUTES'
)
GROUP BY
window_start,
source_currency_code,
target_currency_code EMIT ON WINDOW CLOSE