portfolio_fx_exposure_delta_mv · opportunity

materialized view · opportunity.portfolio_fx_exposure_delta_mv Explain plan ▶

Parallelism

2

Actors

29 / 29

running

Distribution

HASH

Rows

1,144

State size

33.1 KiB

Created

2026-08-25 13:17

Initialized

2026-08-25 13:16

Fragment flags

LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN

Actors

Actor	Fragment	Worker	State
166777	20104	33	running
166778	20104	33	running
166779	20103	33	running
166780	20103	33	running
166781	20109	33	running
166782	20109	33	running
166783	20114	33	running
166784	20114	33	running
166785	20107	33	running
166786	20107	33	running
166787	20108	33	running
166788	20108	33	running

+ 17 more actor(s) (29 running)

sql · opportunity.portfolio_fx_exposure_delta_mv — click to expand

CREATE MATERIALIZED VIEW opportunity.portfolio_fx_exposure_delta_mv AS
SELECT
  pag.portfolio_id,
  c.dim_balance_date,
  p.base_currency_code AS currency_code,
  SUM(c.weight) AS fx_exposure_pct
FROM insights.position_by_currency_mv AS c
JOIN insights.portfolio_to_account_groups_mv AS pag
  ON pag.account_group_id = c.account_group_id AND pag.type = 'all'
JOIN olap.portfolios_dm AS p
  ON p.portfolio_id = pag.portfolio_id
LEFT JOIN asset_service.currencies_dm AS cur
  ON cur.code = p.base_currency_code
WHERE
  c.position_type = 'POSITION'
  AND c.source_entity_type = 'portfolio'
  AND NOT c.item_id IS NULL
  AND (
    p.base_currency_code IS NULL OR c.item_id <> p.base_currency_code
  )
  AND (
    cur.anchor_currency_code IS NULL OR c.item_id <> cur.anchor_currency_code
  )
  AND CAST(c.dim_balance_date AS TIMESTAMPTZ) >= CURRENT_TIMESTAMP - INTERVAL '30 DAYS'
GROUP BY
  pag.portfolio_id,
  c.dim_balance_date,
  p.base_currency_code

Lineage · opportunity.portfolio_fx_exposure_delta_mv 7 objects

Direct (1-hop) dependencies from rw_depend, across schemas. Click a neighbor to expand its dependencies; ⌘/Ctrl-click opens its page. Drag to pan, scroll to zoom. External source/sink endpoints (Kafka, Iceberg) are not shown.

RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local