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

← cluster alinma_bff objects report_position_daily_mv explain
Overview Objects Graph History
materialized view · alinma_bff.report_position_daily_mv profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
22 operators
Materialize · alinma_bff.report_position_daily_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · portfolio_to_account_groups_mv.account_group_id = position_…
— — 2 actors
HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = position_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · position_summary_mv_next
0% idle 2 actors
StreamScan · position_summary_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · portfolio_to_account_groups_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · alinma_bff.report_position_daily_mv Materialize alinma_bff.report_posit… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · portfolio_to_account_groups_mv.account_group_id = position_… SyncLogStore Inner · portfolio_to_ac… — · 2 actors HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = position_… HashJoin Inner · portfolio_to_ac… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · position_summary_mv_next Filter position_summary_mv_next idle · 2 actors StreamScan · position_summary_mv_next StreamScan position_summary_mv_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · portfolio_to_account_groups_mv StreamScan portfolio_to_account_gr… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 64225 (Actor 747267,747266)
StreamMaterialize { columns: [portfolio_id, account_group_type, dim_balance_date, currency_code, market_value, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, accrued_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, portfolio_to_account_groups_mv.account_group_id(hidden), portfolio_to_account_groups_mv.$src(hidden), position_summary_mv_next.account_group_id(hidden), position_summary_mv_next.source_entity_type(hidden), position_summary_mv_next.position_type(hidden)], stream_key: [portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.source_entity_type, dim_balance_date, currency_code, position_summary_mv_next.position_type], pk_columns: [portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.source_entity_type, dim_balance_date, currency_code, position_summary_mv_next.position_type], pk_conflict: NoCheck }
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ]
├── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ]
└── MergeExecutor
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ]
    └── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ]

Fragment 64226 (Actor 747270,747271)
StreamSyncLogStore
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ]
├── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ]
└── StreamHashJoin { type: Inner, predicate: portfolio_to_account_groups_mv.account_group_id = position_summary_mv_next.account_group_id }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ]
    ├── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ]
    ├── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ], stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ] }

Fragment 64227 (Actor 747273,747272)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.account_group_id] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 64228 (Actor 745479,745480)
StreamTableScan { table: portfolio_to_account_groups_mv, columns: [portfolio_id, account_group_id, type, $src] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
├── Upstream { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }

Fragment 64229 (Actor 747275,747274)
StreamLocalityProvider { locality_columns: [position_summary_mv_next.account_group_id] } { output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ], stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ] }
└── MergeExecutor { output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ], stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ] }

Fragment 64230 (Actor 747286,747287)
StreamFilter { predicate: (position_summary_mv_next.position_type = 'POSITION':Varchar) AND (position_summary_mv_next.source_entity_type = 'portfolio':Varchar) }
├── output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ]
├── stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ]
└── StreamTableScan { table: position_summary_mv_next, columns: [account_group_id, dim_balance_date, currency_code, market_value, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, accrued_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, source_entity_type, position_type] }
    ├── output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.market_value, position_summary_mv_next.fair_value, position_summary_mv_next.accrued_value, position_summary_mv_next.relationship_value, position_summary_mv_next.fair_relationship_value, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.accrued_value_system_currency, position_summary_mv_next.relationship_value_system_currency, position_summary_mv_next.fair_relationship_value_system_currency, position_summary_mv_next.source_entity_type, position_summary_mv_next.position_type ]
    ├── stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ]
    ├── Upstream { output: [ account_group_id, dim_balance_date, currency_code, market_value, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, accrued_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, source_entity_type, position_type ], stream key: [] }
    └── BatchPlanNode { output: [ account_group_id, dim_balance_date, currency_code, market_value, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, accrued_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, source_entity_type, position_type ], stream key: [] }