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

← cluster alinma_bff objects report_flows_daily_mv explain
Overview Objects Graph History
materialized view · alinma_bff.report_flows_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_flows_daily_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · portfolio_to_account_groups_mv.account_group_id = flow_by_t…
— — 2 actors
HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = flow_by_t… 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 · flow_by_transaction_type_mv_next
0% idle 2 actors
StreamScan · flow_by_transaction_type_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_flows_daily_mv Materialize alinma_bff.report_flows… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · portfolio_to_account_groups_mv.account_group_id = flow_by_t… SyncLogStore Inner · portfolio_to_ac… — · 2 actors HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = flow_by_t… 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 · flow_by_transaction_type_mv_next Filter flow_by_transaction_typ… idle · 2 actors StreamScan · flow_by_transaction_type_mv_next StreamScan flow_by_transaction_typ… 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 61601 (Actor 739586,739585)
StreamMaterialize { columns: [portfolio_id, account_group_type, dim_transaction_date, transaction_type, currency_code, net_flow, net_flow_system_currency, cumulative_net_flow, portfolio_to_account_groups_mv.account_group_id(hidden), portfolio_to_account_groups_mv.$src(hidden), flow_by_transaction_type_mv_next.account_group_id(hidden), flow_by_transaction_type_mv_next.position_type(hidden)], stream_key: [portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, transaction_type, flow_by_transaction_type_mv_next.position_type, dim_transaction_date, currency_code], pk_columns: [portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, transaction_type, flow_by_transaction_type_mv_next.position_type, dim_transaction_date, currency_code], pk_conflict: NoCheck }
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_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, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ]
└── MergeExecutor
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_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, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ]

Fragment 61602 (Actor 739584,739583)
StreamSyncLogStore
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_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, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ]
└── StreamHashJoin { type: Inner, predicate: portfolio_to_account_groups_mv.account_group_id = flow_by_transaction_type_mv_next.account_group_id }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_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, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ]
    ├── 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: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, flow_by_transaction_type_mv_next.position_type ], stream key: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ] }

Fragment 61603 (Actor 739589,739590)
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 61604 (Actor 739559,739560)
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 61605 (Actor 739595,739596)
StreamLocalityProvider { locality_columns: [flow_by_transaction_type_mv_next.account_group_id] } { output: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, flow_by_transaction_type_mv_next.position_type ], stream key: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ] }
└── MergeExecutor { output: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, flow_by_transaction_type_mv_next.position_type ], stream key: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ] }

Fragment 61606 (Actor 739561,739562)
StreamFilter { predicate: (flow_by_transaction_type_mv_next.position_type = 'POSITION':Varchar) } { output: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, flow_by_transaction_type_mv_next.position_type ], stream key: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ] }
└── StreamTableScan { table: flow_by_transaction_type_mv_next, columns: [account_group_id, dim_transaction_date, transaction_type, currency_code, net_flow, net_flow_system_currency, cumulative_net_flow, position_type] }
    ├── output: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.currency_code, flow_by_transaction_type_mv_next.net_flow, flow_by_transaction_type_mv_next.net_flow_system_currency, flow_by_transaction_type_mv_next.cumulative_net_flow, flow_by_transaction_type_mv_next.position_type ]
    ├── stream key: [ flow_by_transaction_type_mv_next.account_group_id, flow_by_transaction_type_mv_next.transaction_type, flow_by_transaction_type_mv_next.position_type, flow_by_transaction_type_mv_next.dim_transaction_date, flow_by_transaction_type_mv_next.currency_code ]
    ├── Upstream { output: [ account_group_id, dim_transaction_date, transaction_type, currency_code, net_flow, net_flow_system_currency, cumulative_net_flow, position_type ], stream key: [] }
    └── BatchPlanNode { output: [ account_group_id, dim_transaction_date, transaction_type, currency_code, net_flow, net_flow_system_currency, cumulative_net_flow, position_type ], stream key: [] }