RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster alpheya_agent objects party_position_by_asset_mv
Overview Objects Graph History
materialized view · alpheya_agent.party_position_by_asset_mv Explain plan ▶
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
71
State size
6.3 KiB
Created
2026-08-25 13:24
Initialized
2026-08-25 13:23
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
167102 20192 33 running
167103 20192 33 running
167104 20188 33 running
167105 20188 33 running
167106 20190 33 running
167107 20190 33 running
167108 20189 33 running
167109 20189 33 running
167110 20187 33 running
167111 20187 33 running
167112 20191 33 running
167113 20191 33 running
sql · alpheya_agent.party_position_by_asset_mv — click to expand 
CREATE MATERIALIZED VIEW alpheya_agent.party_position_by_asset_mv AS
SELECT
  pag.party_id,
  pag.type AS account_group_type,
  p.dim_balance_date AS as_of_date,
  p.asset_id,
  SUM(p.market_value_system_currency) AS market_value_system,
  'USD' AS system_currency_code
FROM insights.position_by_asset_mv AS p
JOIN insights.party_to_account_groups_mv AS pag
  ON pag.account_group_id = p.account_group_id
WHERE
  p.source_entity_type = 'party' AND p.position_type = 'POSITION'
GROUP BY
  pag.party_id,
  pag.type,
  p.dim_balance_date,
  p.asset_id
Lineage · alpheya_agent.party_position_by_asset_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.