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

← cluster opportunity objects portfolio_cash_ratio_mv
Overview Objects Graph History
materialized view · opportunity.portfolio_cash_ratio_mv Explain plan ▶
Parallelism
2
Actors
13 / 13
running
Distribution
HASH
Rows
3,288
State size
82.5 KiB
Created
2026-08-25 12:53
Initialized
2026-08-25 12:52
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
165559 19782 33 running
165560 19782 33 running
165561 19783 33 running
165562 19784 33 running
165563 19784 33 running
165564 19779 33 running
165565 19779 33 running
165566 19781 33 running
165567 19781 33 running
165568 19785 33 running
165569 19785 33 running
165570 19780 33 running
+ 1 more actor(s) (13 running)
sql · opportunity.portfolio_cash_ratio_mv — click to expand
CREATE MATERIALIZED VIEW opportunity.portfolio_cash_ratio_mv AS
SELECT
  pag.portfolio_id,
  pv.dim_value_date,
  pv.group_currency AS currency_code,
  COALESCE(SUM(pv.market_value_group) FILTER(WHERE
    pv.asset_type = 'CASH'), 0) AS cash_value,
  SUM(pv.market_value_group) AS total_value,
  COALESCE(SUM(pv.market_value_group) FILTER(WHERE
    pv.asset_type = 'CASH'), 0) / SUM(pv.market_value_group) AS cash_ratio,
  'GET_PORTFOLIO_IDLE_CASH_PERCENTAGE' AS activity_name
FROM insights.position_values_mv AS pv
JOIN insights.portfolio_to_account_groups_mv AS pag
  ON pag.account_group_id = pv.account_group_id AND pag.type = 'all'
WHERE
  pv.position_type = 'ASSET'
  AND CAST(pv.dim_value_date AS TIMESTAMPTZ) >= CURRENT_TIMESTAMP - INTERVAL '30 DAYS'
GROUP BY
  pag.portfolio_id,
  pv.dim_value_date,
  pv.group_currency
HAVING
  SUM(pv.market_value_group) > 0
Lineage · opportunity.portfolio_cash_ratio_mv 4 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.