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

← cluster opportunity objects portfolio_balance_delta_mv
Overview Objects Graph History
materialized view · opportunity.portfolio_balance_delta_mv Explain plan ▶
Parallelism
2
Actors
21 / 21
running
Distribution
HASH
Rows
2,571
State size
94.9 KiB
Created
2026-08-25 13:09
Initialized
2026-08-25 13:08
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
166445 20027 33 running
166446 20027 33 running
166447 20025 33 running
166448 20025 33 running
166449 20022 33 running
166450 20022 33 running
166451 20028 33 running
166452 20028 33 running
166453 20021 33 running
166454 20021 33 running
166455 20026 33 running
166456 20026 33 running
+ 9 more actor(s) (21 running)
sql · opportunity.portfolio_balance_delta_mv — click to expand 
CREATE MATERIALIZED VIEW opportunity.portfolio_balance_delta_mv AS
SELECT
  pag.portfolio_id,
  b.dim_balance_date,
  b.currency_code,
  b.market_value,
  prev.market_value AS prev_market_value
FROM insights.position_summary_mv AS b
JOIN insights.position_summary_mv AS prev
  ON prev.account_group_id = b.account_group_id
  AND prev.position_type = b.position_type
  AND prev.currency_code = b.currency_code
  AND prev.dim_balance_date = b.dim_balance_date - 1
JOIN insights.portfolio_to_account_groups_mv AS pag
  ON pag.account_group_id = b.account_group_id AND pag.type = 'all'
WHERE
  b.position_type = 'POSITION'
  AND prev.market_value > 0
  AND CAST(b.dim_balance_date AS TIMESTAMPTZ) >= CURRENT_TIMESTAMP - INTERVAL '30 DAYS'
Lineage · opportunity.portfolio_balance_delta_mv 6 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.