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

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

Job is idle — throughput ~0; structure shown.

Aggregation state — unbounded unless keyed or temporally filtered
8 operators
Materialize · insights.intraday_position_summary_mv
0% idle 2 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · intraday_position_asset_values_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.intraday_position_summary_mv Materialize insights.intraday_posit… idle · 2 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_position_asset_values_mv_next StreamScan intraday_position_asset… 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 25862 (Actor 129771,129772)
StreamMaterialize { columns: [account_group_id, position_type, currency_code, market_value, total_average_cost, fair_value, accrued_value, market_value_system_currency, total_average_cost_system_currency, fair_value_system_currency, accrued_value_system_currency, positions_count, change_time], stream_key: [account_group_id, currency_code, position_type], pk_columns: [account_group_id, currency_code, position_type], pk_conflict: NoCheck }
├── output: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.position_type, intraday_position_asset_values_mv_next.group_currency, sum(intraday_position_asset_values_mv_next.market_value), sum(intraday_position_asset_values_mv_next.average_cost), sum(intraday_position_asset_values_mv_next.fair_value), sum(intraday_position_asset_values_mv_next.accrued_value), sum(intraday_position_asset_values_mv_next.market_value_system), sum(intraday_position_asset_values_mv_next.average_cost_system), sum(intraday_position_asset_values_mv_next.fair_value_system), sum(intraday_position_asset_values_mv_next.accrued_value_system), sum(intraday_position_asset_values_mv_next.positions_count), max(intraday_position_asset_values_mv_next.change_time) ]
├── stream key: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.group_currency, intraday_position_asset_values_mv_next.position_type ]
└── StreamProject { exprs: [intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.position_type, intraday_position_asset_values_mv_next.group_currency, sum(intraday_position_asset_values_mv_next.market_value), sum(intraday_position_asset_values_mv_next.average_cost), sum(intraday_position_asset_values_mv_next.fair_value), sum(intraday_position_asset_values_mv_next.accrued_value), sum(intraday_position_asset_values_mv_next.market_value_system), sum(intraday_position_asset_values_mv_next.average_cost_system), sum(intraday_position_asset_values_mv_next.fair_value_system), sum(intraday_position_asset_values_mv_next.accrued_value_system), sum(intraday_position_asset_values_mv_next.positions_count), max(intraday_position_asset_values_mv_next.change_time)] }
    ├── output: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.position_type, intraday_position_asset_values_mv_next.group_currency, sum(intraday_position_asset_values_mv_next.market_value), sum(intraday_position_asset_values_mv_next.average_cost), sum(intraday_position_asset_values_mv_next.fair_value), sum(intraday_position_asset_values_mv_next.accrued_value), sum(intraday_position_asset_values_mv_next.market_value_system), sum(intraday_position_asset_values_mv_next.average_cost_system), sum(intraday_position_asset_values_mv_next.fair_value_system), sum(intraday_position_asset_values_mv_next.accrued_value_system), sum(intraday_position_asset_values_mv_next.positions_count), max(intraday_position_asset_values_mv_next.change_time) ]
    ├── stream key: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.group_currency, intraday_position_asset_values_mv_next.position_type ]
    └── StreamHashAgg { group_key: [intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.group_currency, intraday_position_asset_values_mv_next.position_type], aggs: [sum(intraday_position_asset_values_mv_next.market_value), sum(intraday_position_asset_values_mv_next.average_cost), sum(intraday_position_asset_values_mv_next.fair_value), sum(intraday_position_asset_values_mv_next.accrued_value), sum(intraday_position_asset_values_mv_next.market_value_system), sum(intraday_position_asset_values_mv_next.average_cost_system), sum(intraday_position_asset_values_mv_next.fair_value_system), sum(intraday_position_asset_values_mv_next.accrued_value_system), sum(intraday_position_asset_values_mv_next.positions_count), max(intraday_position_asset_values_mv_next.change_time), count] }
        ├── output: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.group_currency, intraday_position_asset_values_mv_next.position_type, sum(intraday_position_asset_values_mv_next.market_value), sum(intraday_position_asset_values_mv_next.average_cost), sum(intraday_position_asset_values_mv_next.fair_value), sum(intraday_position_asset_values_mv_next.accrued_value), sum(intraday_position_asset_values_mv_next.market_value_system), sum(intraday_position_asset_values_mv_next.average_cost_system), sum(intraday_position_asset_values_mv_next.fair_value_system), sum(intraday_position_asset_values_mv_next.accrued_value_system), sum(intraday_position_asset_values_mv_next.positions_count), max(intraday_position_asset_values_mv_next.change_time), count ]
        ├── stream key: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.group_currency, intraday_position_asset_values_mv_next.position_type ]
        └── MergeExecutor
            ├── output: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.group_currency, intraday_position_asset_values_mv_next.position_type, intraday_position_asset_values_mv_next.market_value, intraday_position_asset_values_mv_next.average_cost, intraday_position_asset_values_mv_next.fair_value, intraday_position_asset_values_mv_next.accrued_value, intraday_position_asset_values_mv_next.market_value_system, intraday_position_asset_values_mv_next.average_cost_system, intraday_position_asset_values_mv_next.fair_value_system, intraday_position_asset_values_mv_next.accrued_value_system, intraday_position_asset_values_mv_next.positions_count, intraday_position_asset_values_mv_next.change_time, intraday_position_asset_values_mv_next.asset_id ]
            └── stream key: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.asset_id, intraday_position_asset_values_mv_next.position_type, intraday_position_asset_values_mv_next.group_currency ]

Fragment 25863 (Actor 129773,129774)
StreamTableScan { table: intraday_position_asset_values_mv_next, columns: [account_group_id, group_currency, position_type, market_value, average_cost, fair_value, accrued_value, market_value_system, average_cost_system, fair_value_system, accrued_value_system, positions_count, change_time, asset_id] }
├── output: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.group_currency, intraday_position_asset_values_mv_next.position_type, intraday_position_asset_values_mv_next.market_value, intraday_position_asset_values_mv_next.average_cost, intraday_position_asset_values_mv_next.fair_value, intraday_position_asset_values_mv_next.accrued_value, intraday_position_asset_values_mv_next.market_value_system, intraday_position_asset_values_mv_next.average_cost_system, intraday_position_asset_values_mv_next.fair_value_system, intraday_position_asset_values_mv_next.accrued_value_system, intraday_position_asset_values_mv_next.positions_count, intraday_position_asset_values_mv_next.change_time, intraday_position_asset_values_mv_next.asset_id ]
├── stream key: [ intraday_position_asset_values_mv_next.account_group_id, intraday_position_asset_values_mv_next.asset_id, intraday_position_asset_values_mv_next.position_type, intraday_position_asset_values_mv_next.group_currency ]
├── Upstream { output: [ account_group_id, group_currency, position_type, market_value, average_cost, fair_value, accrued_value, market_value_system, average_cost_system, fair_value_system, accrued_value_system, positions_count, change_time, asset_id ], stream key: [] }
└── BatchPlanNode { output: [ account_group_id, group_currency, position_type, market_value, average_cost, fair_value, accrued_value, market_value_system, average_cost_system, fair_value_system, accrued_value_system, positions_count, change_time, asset_id ], stream key: [] }