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

← cluster alpheya_experience_bff objects report_flows_daily_mv
Overview Objects Graph History
materialized view · alpheya_experience_bff.report_flows_daily_mv Explain plan ▶
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
577
State size
139.8 KiB
Created
2026-08-25 12:43
Initialized
2026-08-25 12:43
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
165158 19648 33 running
165159 19648 33 running
165160 19646 33 running
165161 19646 33 running
165162 19645 33 running
165163 19645 33 running
165164 19647 33 running
165165 19647 33 running
165166 19643 33 running
165167 19643 33 running
165168 19644 33 running
165169 19644 33 running
sql · alpheya_experience_bff.report_flows_daily_mv — click to expand 
CREATE MATERIALIZED VIEW alpheya_experience_bff.report_flows_daily_mv AS
SELECT
  pag.portfolio_id,
  pag.type AS account_group_type,
  f.dim_transaction_date,
  f.transaction_type,
  f.currency_code,
  f.net_flow,
  f.net_flow_system_currency,
  f.cumulative_net_flow
FROM insights.portfolio_to_account_groups_mv AS pag
JOIN insights.flow_by_transaction_type_mv AS f
  ON f.account_group_id = pag.account_group_id AND f.position_type = 'POSITION'
Lineage · alpheya_experience_bff.report_flows_daily_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.