RWM Console cluster: risingwave-alinma.alinma-rw.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
1,286
State size
178.1 KiB
Created
2026-08-19 22:47
Initialized
2026-08-19 22:47
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
738782 61571 51 running
738783 61571 51 running
738784 61572 51 running
738785 61572 51 running
738786 61573 51 running
738787 61573 51 running
738788 61575 51 running
738789 61574 51 running
738790 61574 51 running
739469 61576 51 running
739470 61576 51 running
739471 61577 51 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.