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

← cluster alpheya_experience_bff objects client_fee_totals_mv
Overview Objects Graph History
materialized view · alpheya_experience_bff.client_fee_totals_mv Explain plan ▶
Parallelism
2
Actors
20 / 20
running
Distribution
HASH
Rows
0
State size
—
Created
2026-08-21 07:14
Initialized
2026-08-21 07:13
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
160070 18674 33 running
160071 18674 33 running
160072 18676 33 running
160073 18676 33 running
160074 18675 33 running
160075 18675 33 running
160076 18677 33 running
160077 18677 33 running
160078 18678 33 running
160079 18678 33 running
160080 18679 33 running
160081 18679 33 running
+ 8 more actor(s) (20 running)
sql · alpheya_experience_bff.client_fee_totals_mv — click to expand 
CREATE MATERIALIZED VIEW alpheya_experience_bff.client_fee_totals_mv AS
SELECT
  cag.client_id,
  cag.type AS account_group_type,
  SUM(fv.net_value_group) AS total_fees,
  SUM(CASE WHEN ft.fee_type = 'TRANSACTIONAL' THEN fv.net_value_group ELSE 0 END) AS transactional_fees,
  SUM(CASE WHEN ft.fee_type = 'NON_TRANSACTIONAL' THEN fv.net_value_group ELSE 0 END) AS non_transactional_fees,
  SUM(fv.net_value_system) AS total_fees_system_currency,
  SUM(CASE WHEN ft.fee_type = 'TRANSACTIONAL' THEN fv.net_value_system ELSE 0 END) AS transactional_fees_system_currency,
  SUM(CASE WHEN ft.fee_type = 'NON_TRANSACTIONAL' THEN fv.net_value_system ELSE 0 END) AS non_transactional_fees_system_currency
FROM insights.flow_values_mv AS fv
JOIN olap.fee_transactions_dm AS ft
  ON ft.transaction_id = fv.transaction_id
JOIN insights.client_to_account_groups_mv AS cag
  ON cag.account_group_id = fv.account_group_id
WHERE
  fv.transaction_type = 'FEE' AND fv.position_type = 'POSITION'
GROUP BY
  cag.client_id,
  cag.type
Lineage · alpheya_experience_bff.client_fee_totals_mv 5 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.