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

← cluster insights objects intraday_position_by_distribution_mv
Overview Objects Graph History
materialized view · insights.intraday_position_by_distribution_mv
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
0
State size
—
Created
2026-06-30 21:57
Initialized
2026-06-30 21:56
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
55141 3071 3 running
55142 3071 3 running
55143 3072 3 running
55144 3072 3 running
55159 3073 3 running
55160 3073 3 running
55161 3074 3 running
55162 3074 3 running
55163 3075 3 running
55164 3075 3 running
sql · insights.intraday_position_by_distribution_mv — click to expand 
CREATE MATERIALIZED VIEW insights.intraday_position_by_distribution_mv AS
SELECT
  av.account_group_id,
  av.position_type,
  ad.distribution_type,
  ad.item_id,
  ad.taxonomy_node_id,
  av.group_currency AS currency_code,
  SUM(av.market_value * ad.share) AS market_value,
  SUM(av.average_cost * ad.share) AS total_average_cost,
  SUM(av.fair_value * ad.share) AS fair_value,
  SUM(av.accrued_value * ad.share) AS accrued_value,
  SUM(av.market_value_system * ad.share) AS market_value_system_currency,
  SUM(av.average_cost_system * ad.share) AS total_average_cost_system_currency,
  SUM(av.fair_value_system * ad.share) AS fair_value_system_currency,
  SUM(av.accrued_value_system * ad.share) AS accrued_value_system_currency,
  SUM(av.market_value_system * ad.share) / NULLIF(b.market_value_system_currency, 0) AS weight,
  SUM(av.fair_value_system * ad.share) / NULLIF(b.fair_value_system_currency, 0) AS fair_value_weight,
  MAX(av.change_time) AS change_time
FROM insights.intraday_position_asset_values_mv AS av
JOIN insights.asset_distributions_for_consumers_mv AS ad
  ON ad.asset_id = av.asset_id
  AND CAST(av.change_time AS DATE) >= ad.effective_start_date
  AND CAST(av.change_time AS DATE) < ad.effective_end_date
JOIN insights.intraday_position_summary_mv AS b
  ON b.account_group_id = av.account_group_id AND b.position_type = av.position_type
GROUP BY
  av.account_group_id,
  av.group_currency,
  av.position_type,
  ad.distribution_type,
  ad.item_id,
  ad.taxonomy_node_id,
  b.market_value_system_currency,
  b.fair_value_system_currency
Lineage · insights.intraday_position_by_distribution_mv 8 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.