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-26 08:18
Initialized
2026-08-26 08:18
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
120759 25109 26 running
120760 25109 26 running
120761 25105 26 running
120762 25105 26 running
120763 25104 26 running
120764 25104 26 running
120765 25106 26 running
120766 25106 26 running
120767 25107 26 running
120768 25107 26 running
120769 25108 26 running
120770 25108 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.