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

← cluster insights objects intraday_position_by_asset_mv
Overview Objects Graph History
materialized view · insights.intraday_position_by_asset_mv Explain plan ▶
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
35,437
State size
12.4 MiB
Created
2026-08-25 16:47
Initialized
2026-08-25 16:47
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
113968 24444 26 running
113969 24444 26 running
113970 24442 26 running
113971 24442 26 running
113972 24441 26 running
113973 24441 26 running
113974 24443 26 running
113975 24443 26 running
113976 24446 26 running
113977 24446 26 running
113978 24445 26 running
113979 24445 26 running
sql · insights.intraday_position_by_asset_mv — click to expand
CREATE MATERIALIZED VIEW insights.intraday_position_by_asset_mv AS
SELECT
  av.account_group_id,
  av.position_type,
  av.asset_id,
  a.issue_currency_code AS asset_currency,
  av.group_currency AS currency_code,
  av.market_value,
  av.average_cost AS total_average_cost,
  av.fair_value,
  av.accrued_value,
  av.market_value_system AS market_value_system_currency,
  av.average_cost_system AS total_average_cost_system_currency,
  av.fair_value_system AS fair_value_system_currency,
  av.accrued_value_system AS accrued_value_system_currency,
  av.market_value_asset AS market_value_asset_currency,
  av.average_cost_asset AS total_average_cost_asset_currency,
  av.fair_value_asset AS fair_value_asset_currency,
  av.quantity,
  av.market_value_system / NULLIF(b.market_value_system_currency, 0) AS weight,
  av.fair_value_system / NULLIF(b.fair_value_system_currency, 0) AS fair_value_weight,
  av.change_time
FROM insights.intraday_position_asset_values_mv AS av
LEFT JOIN asset_service.assets_dm AS a
  ON a.id = av.asset_id
JOIN insights.intraday_position_summary_mv AS b
  ON b.account_group_id = av.account_group_id AND b.position_type = av.position_type
Lineage · insights.intraday_position_by_asset_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.