RWM Console cluster: risingwave.platform.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
10 / 10
running
Distribution
HASH
Rows
0
State size
Created
2026-08-18 09:50
Initialized
2026-08-18 09:50
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
33211 11632 33 running
33212 11632 33 running
33215 11633 33 running
33216 11633 33 running
33217 11634 33 running
33218 11634 33 running
33229 11635 33 running
33230 11635 33 running
33231 11636 33 running
33232 11636 33 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 = 'SAR' 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) = 'SAR'
        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 = 'SAR'
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 = 'SAR'
WHERE
  v.disabled_at IS NULL
  AND (
    NOT fxm.rate IS NULL OR v.market_value_currency = 'SAR'
  )
  AND (
    NOT fxc.rate IS NULL
    OR COALESCE(v.average_cost_currency, v.market_value_currency) = 'SAR'
    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.