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

← cluster alpheya_experience_bff objects advisor_kpis_mv
Overview Objects Graph History
materialized view · alpheya_experience_bff.advisor_kpis_mv Explain plan ▶
Parallelism
2
Actors
8 / 8
running
Distribution
HASH
Rows
41
State size
6.4 KiB
Created
2026-08-25 12:54
Initialized
2026-08-25 12:53
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
165588 19788 33 running
165589 19788 33 running
165590 19789 33 running
165591 19789 33 running
165592 19790 33 running
165593 19790 33 running
165594 19791 33 running
165595 19791 33 running
sql · alpheya_experience_bff.advisor_kpis_mv — click to expand
CREATE MATERIALIZED VIEW alpheya_experience_bff.advisor_kpis_mv AS
SELECT
  cnt.user_id,
  cnt.clients_count,
  cnt.portfolios_count,
  cnt.accounts_count,
  COALESCE(val.total_financing, 0) AS total_financing,
  COALESCE(val.total_relationship_value, 0) AS total_relationship_value,
  COALESCE(val.total_net_assets, 0) AS total_net_assets,
  COALESCE(val.total_deposits, 0) AS total_deposits,
  COALESCE(val.total_aum, 0) AS total_aum,
  CAST('USD' AS VARCHAR) AS currency_code,
  COALESCE(val.updated_at, CAST('1970-01-01 00:00:00 UTC' AS TIMESTAMPTZ)) AS updated_at
FROM alpheya_experience_bff.advisor_kpi_counts_mv AS cnt
LEFT JOIN alpheya_experience_bff.advisor_kpi_values_mv AS val
  ON val.user_id = cnt.user_id
Lineage · alpheya_experience_bff.advisor_kpis_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.