| Actor | Fragment | Worker | State |
|---|---|---|---|
| 54060 | 2464 | 3 | running |
| 54061 | 2464 | 3 | running |
| 54062 | 2465 | 3 | running |
| 54063 | 2465 | 3 | 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