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

← cluster insights objects settled_position_valuations_mv
Overview Objects Graph History
materialized view · insights.settled_position_valuations_mv Explain plan ▶
Parallelism
2
Actors
17 / 17
running
Distribution
HASH
Rows
1,472
State size
423.3 KiB
Created
2026-08-24 15:32
Initialized
2026-08-24 15:32
Fragment flags
MVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
104707 23631 26 running
104708 23631 26 running
104709 23628 26 running
104710 23628 26 running
104711 23627 26 running
104712 23627 26 running
104713 23629 26 running
104714 23629 26 running
104715 23630 26 running
104716 23630 26 running
104717 23632 26 running
104718 23633 26 running
+ 5 more actor(s) (17 running)
sql · insights.settled_position_valuations_mv — click to expand
CREATE MATERIALIZED VIEW insights.settled_position_valuations_mv AS
WITH latest_position AS (
  SELECT
    account_id,
    asset_id,
    currency_code,
    dim_settlement_date,
    settled_quantity,
    settled_value
  FROM (
    SELECT
      account_id,
      asset_id,
      currency_code,
      dim_settlement_date,
      settled_quantity,
      settled_value,
      ROW_NUMBER() OVER (
        PARTITION BY account_id, asset_id, currency_code
        ORDER BY dim_settlement_date DESC
      ) AS rn
    FROM insights.settled_position_series_mv AS settled_position_series_mv_next
    WHERE
      dim_settlement_date <= CURRENT_TIMESTAMP
  ) AS ranked
  WHERE
    rn = 1
)
SELECT
  p.account_id,
  p.asset_id,
  p.currency_code,
  p.dim_settlement_date AS last_settlement_date,
  p.settled_quantity,
  p.settled_value,
  px.price,
  px.price_date,
  p.settled_quantity * px.price AS market_value,
  p.settled_quantity * px.price * COALESCE(fx.rate, CASE WHEN p.currency_code = 'AED' THEN 1 ELSE NULL END) AS market_value_system_currency,
  cb.average_cost_per_unit,
  cb.average_cost_per_unit_system_currency,
  cb.purchased_quantity AS baseline_purchased_quantity,
  cb.dim_value_date AS cost_basis_date,
  cb.m_is_stub AS cost_basis_is_stub,
  p.settled_quantity * cb.average_cost_per_unit AS total_cost,
  cb.total_cost_system_currency,
  cb.cost_fx_provenance
FROM latest_position AS p
LEFT JOIN insights.settled_cost_basis_latest_mv AS cb
  ON cb.account_id = p.account_id AND cb.asset_id = p.asset_id
LEFT JOIN insights.asset_latest_price_mv AS px
  ON px.asset_id = p.asset_id
LEFT JOIN insights.fx_rates_snapshot_mv AS fx
  ON fx.source_currency_code = p.currency_code AND fx.target_currency_code = 'AED'
Lineage · insights.settled_position_valuations_mv 6 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.