RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local

← cluster insights objects private_asset_valuations_mv
Overview Objects Graph History
materialized view · insights.private_asset_valuations_mv Explain plan ▶
Parallelism
2
Actors
14 / 14
running
Distribution
HASH
Rows
0
State size
Created
2026-08-19 06:32
Initialized
2026-08-19 06:32
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
99760 22185 26 running
99761 22185 26 running
99762 22186 26 running
99763 22186 26 running
99768 22181 26 running
99769 22181 26 running
99772 22180 26 running
99773 22180 26 running
99774 22183 26 running
99775 22183 26 running
99776 22182 26 running
99777 22182 26 running
+ 2 more actor(s) (14 running)
sql · insights.private_asset_valuations_mv — click to expand
CREATE MATERIALIZED VIEW insights.private_asset_valuations_mv AS
SELECT
  v.asset_id,
  v.fact_date,
  v.market_value_currency,
  v.market_value * COALESCE(fxm.rate, CASE WHEN v.market_value_currency = 'AED' THEN 1 ELSE NULL END) AS value_system_currency,
  CASE
    WHEN COALESCE(v.average_cost, 0) = 0
    THEN 0
    ELSE v.average_cost * COALESCE(
      fxc.rate,
      CASE
        WHEN COALESCE(v.average_cost_currency, v.market_value_currency) = 'AED'
        THEN 1
        ELSE NULL
      END
    )
  END AS cost_system_currency
FROM olap.private_asset_valuations_ft AS v
LEFT JOIN insights.fx_rates_snapshot_mv AS fxm
  ON fxm.source_currency_code = v.market_value_currency
  AND fxm.target_currency_code = 'AED'
LEFT JOIN insights.fx_rates_snapshot_mv AS fxc
  ON fxc.source_currency_code = COALESCE(v.average_cost_currency, v.market_value_currency)
  AND fxc.target_currency_code = 'AED'
WHERE
  v.disabled_at IS NULL
  AND (
    NOT fxm.rate IS NULL OR v.market_value_currency = 'AED'
  )
  AND (
    NOT fxc.rate IS NULL
    OR COALESCE(v.average_cost_currency, v.market_value_currency) = 'AED'
    OR COALESCE(v.average_cost, 0) = 0
  )
Lineage · insights.private_asset_valuations_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.