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

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

Job is idle — throughput ~0; structure shown.

Aggregation state — unbounded unless keyed or temporally filteredWindow state — add a WHERE rank <= N to bound it
13 operators
Materialize · insights.settled_cash_balances_mv
0% idle 2 actors
Project
— — 2 actors
OverWindow Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · settled_cash_series_mv_next
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 · insights.settled_cash_balances_mv Materialize insights.settled_cash_b… idle · 2 actors Project Project — · 2 actors OverWindow OverWindow idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · settled_cash_series_mv_next StreamScan settled_cash_series_mv_… 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 62793 (Actor 744618,744619)
StreamMaterialize { columns: [account_id, currency_code, dim_settlement_date, settlement_amount_delta, settled_cash_balance, transaction_count], stream_key: [account_id, currency_code, dim_settlement_date], pk_columns: [account_id, currency_code, dim_settlement_date], pk_conflict: NoCheck }
├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), sum, $expr1 ]
├── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]
└── StreamProject { exprs: [settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), sum, $expr1] }
    ├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), sum, $expr1 ]
    ├── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]
    └── StreamOverWindow { window_functions: [sum(sum(settled_cash_series_mv_next.settlement_amount_delta)) OVER(PARTITION BY settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code ORDER BY settled_cash_series_mv_next.dim_settlement_date ASC ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)] }
        ├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), $expr1, sum ]
        ├── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]
        └── MergeExecutor
            ├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), $expr1 ]
            └── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]

Fragment 62794 (Actor 744621,744620)
StreamProject { exprs: [settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), sum(settled_cash_series_mv_next.transaction_count)::Int64 as $expr1] }
├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), $expr1 ]
├── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]
└── StreamHashAgg { group_key: [settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date], aggs: [sum(settled_cash_series_mv_next.settlement_amount_delta), sum(settled_cash_series_mv_next.transaction_count), count] }
    ├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, sum(settled_cash_series_mv_next.settlement_amount_delta), sum(settled_cash_series_mv_next.transaction_count), count ]
    ├── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]
    └── StreamLocalityProvider { locality_columns: [settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date] }
        ├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, settled_cash_series_mv_next.settlement_amount_delta, settled_cash_series_mv_next.transaction_count, settled_cash_series_mv_next.asset_id ]
        ├── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, settled_cash_series_mv_next.asset_id ]
        └── MergeExecutor
            ├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, settled_cash_series_mv_next.settlement_amount_delta, settled_cash_series_mv_next.transaction_count, settled_cash_series_mv_next.asset_id ]
            └── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.asset_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]

Fragment 62795 (Actor 744623,744622)
StreamTableScan { table: settled_cash_series_mv_next, columns: [account_id, currency_code, dim_settlement_date, settlement_amount_delta, transaction_count, asset_id] }
├── output: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date, settled_cash_series_mv_next.settlement_amount_delta, settled_cash_series_mv_next.transaction_count, settled_cash_series_mv_next.asset_id ]
├── stream key: [ settled_cash_series_mv_next.account_id, settled_cash_series_mv_next.asset_id, settled_cash_series_mv_next.currency_code, settled_cash_series_mv_next.dim_settlement_date ]
├── Upstream { output: [ account_id, currency_code, dim_settlement_date, settlement_amount_delta, transaction_count, asset_id ], stream key: [] }
└── BatchPlanNode { output: [ account_id, currency_code, dim_settlement_date, settlement_amount_delta, transaction_count, asset_id ], stream key: [] }