intraday_position_asset_values_mv · explain

← cluster insights objects intraday_position_asset_values_mv explain
Overview Objects Graph History
materialized view · insights.intraday_position_asset_values_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Aggregation state — unbounded unless keyed or temporally filtered
Heat tree Operator graph
8 operators
Materialize · insights.intraday_position_asset_values_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_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.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 25858 (Actor 129715,129716)
StreamMaterialize { columns: [account_group_id, asset_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, market_value_asset, average_cost_asset, fair_value_asset, quantity, positions_count, change_time], stream_key: [account_group_id, asset_id, position_type, group_currency], pk_columns: [account_group_id, asset_id, position_type, group_currency], pk_conflict: NoCheck }
├── output: [ intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.group_currency, intraday_position_values_mv_next.position_type, sum(intraday_position_values_mv_next.market_value_group), sum(intraday_position_values_mv_next.average_cost_group), sum(intraday_position_values_mv_next.fair_value_group), sum(intraday_position_values_mv_next.accrued_value_group), sum(intraday_position_values_mv_next.market_value_system), sum(intraday_position_values_mv_next.average_cost_system), sum(intraday_position_values_mv_next.fair_value_system), sum(intraday_position_values_mv_next.accrued_value_system), sum(intraday_position_values_mv_next.market_value_asset), sum(intraday_position_values_mv_next.average_cost_asset), sum(intraday_position_values_mv_next.fair_value_asset), sum(intraday_position_values_mv_next.purchased_quantity), count, max(intraday_position_values_mv_next.change_time) ]
├── stream key: [ intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.position_type, intraday_position_values_mv_next.group_currency ]
└── StreamProject { exprs: [intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.group_currency, intraday_position_values_mv_next.position_type, sum(intraday_position_values_mv_next.market_value_group), sum(intraday_position_values_mv_next.average_cost_group), sum(intraday_position_values_mv_next.fair_value_group), sum(intraday_position_values_mv_next.accrued_value_group), sum(intraday_position_values_mv_next.market_value_system), sum(intraday_position_values_mv_next.average_cost_system), sum(intraday_position_values_mv_next.fair_value_system), sum(intraday_position_values_mv_next.accrued_value_system), sum(intraday_position_values_mv_next.market_value_asset), sum(intraday_position_values_mv_next.average_cost_asset), sum(intraday_position_values_mv_next.fair_value_asset), sum(intraday_position_values_mv_next.purchased_quantity), count, max(intraday_position_values_mv_next.change_time)] }
    ├── output: [ intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.group_currency, intraday_position_values_mv_next.position_type, sum(intraday_position_values_mv_next.market_value_group), sum(intraday_position_values_mv_next.average_cost_group), sum(intraday_position_values_mv_next.fair_value_group), sum(intraday_position_values_mv_next.accrued_value_group), sum(intraday_position_values_mv_next.market_value_system), sum(intraday_position_values_mv_next.average_cost_system), sum(intraday_position_values_mv_next.fair_value_system), sum(intraday_position_values_mv_next.accrued_value_system), sum(intraday_position_values_mv_next.market_value_asset), sum(intraday_position_values_mv_next.average_cost_asset), sum(intraday_position_values_mv_next.fair_value_asset), sum(intraday_position_values_mv_next.purchased_quantity), count, max(intraday_position_values_mv_next.change_time) ]
    ├── stream key: [ intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.position_type, intraday_position_values_mv_next.group_currency ]
    └── StreamHashAgg { group_key: [intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.position_type, intraday_position_values_mv_next.group_currency], aggs: [sum(intraday_position_values_mv_next.market_value_group), sum(intraday_position_values_mv_next.average_cost_group), sum(intraday_position_values_mv_next.fair_value_group), sum(intraday_position_values_mv_next.accrued_value_group), sum(intraday_position_values_mv_next.market_value_system), sum(intraday_position_values_mv_next.average_cost_system), sum(intraday_position_values_mv_next.fair_value_system), sum(intraday_position_values_mv_next.accrued_value_system), sum(intraday_position_values_mv_next.market_value_asset), sum(intraday_position_values_mv_next.average_cost_asset), sum(intraday_position_values_mv_next.fair_value_asset), sum(intraday_position_values_mv_next.purchased_quantity), count, max(intraday_position_values_mv_next.change_time)] }
        ├── output: [ intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.position_type, intraday_position_values_mv_next.group_currency, sum(intraday_position_values_mv_next.market_value_group), sum(intraday_position_values_mv_next.average_cost_group), sum(intraday_position_values_mv_next.fair_value_group), sum(intraday_position_values_mv_next.accrued_value_group), sum(intraday_position_values_mv_next.market_value_system), sum(intraday_position_values_mv_next.average_cost_system), sum(intraday_position_values_mv_next.fair_value_system), sum(intraday_position_values_mv_next.accrued_value_system), sum(intraday_position_values_mv_next.market_value_asset), sum(intraday_position_values_mv_next.average_cost_asset), sum(intraday_position_values_mv_next.fair_value_asset), sum(intraday_position_values_mv_next.purchased_quantity), count, max(intraday_position_values_mv_next.change_time) ]
        ├── stream key: [ intraday_position_values_mv_next.account_group_id, intraday_position_values_mv_next.asset_id, intraday_position_values_mv_next.position_type, intraday_position_values_mv_next.group_currency ]
        └── MergeExecutor
            ├── output:
            │   ┌── intraday_position_values_mv_next.account_group_id
            │   ├── intraday_position_values_mv_next.asset_id
            │   ├── intraday_position_values_mv_next.position_type
            │   ├── intraday_position_values_mv_next.group_currency
            │   ├── intraday_position_values_mv_next.purchased_quantity
            │   ├── intraday_position_values_mv_next.market_value_group
            │   ├── intraday_position_values_mv_next.average_cost_group
            │   ├── intraday_position_values_mv_next.fair_value_group
            │   ├── intraday_position_values_mv_next.accrued_value_group
            │   ├── intraday_position_values_mv_next.market_value_system
            │   ├── intraday_position_values_mv_next.average_cost_system
            │   ├── intraday_position_values_mv_next.fair_value_system
            │   ├── intraday_position_values_mv_next.accrued_value_system
            │   ├── intraday_position_values_mv_next.market_value_asset
            │   ├── intraday_position_values_mv_next.average_cost_asset
            │   ├── intraday_position_values_mv_next.fair_value_asset
            │   ├── intraday_position_values_mv_next.change_time
            │   ├── intraday_position_values_mv_next.account_id
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#1
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date#1
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Int32
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#2
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#3
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#4
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.$src
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_id
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_group_id
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
            │   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
            │   ├── intraday_position_values_mv_next.$src
            │   ├── intraday_position_values_mv_next.holding_currency
            │   ├── intraday_position_values_mv_next.intraday_fx_rates_latest_mv_next.target_currency_code
            │   └── intraday_position_values_mv_next.asset_currency
            └── stream key:
                ┌── intraday_position_values_mv_next.account_id
                ├── intraday_position_values_mv_next.asset_id
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#1
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date#1
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Int32
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#2
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#3
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#4
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.$src
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_id
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_group_id
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
                ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
                ├── intraday_position_values_mv_next.$src
                ├── intraday_position_values_mv_next.holding_currency
                ├── intraday_position_values_mv_next.group_currency
                ├── intraday_position_values_mv_next.intraday_fx_rates_latest_mv_next.target_currency_code
                └── intraday_position_values_mv_next.asset_currency

Fragment 25859 (Actor 129718,129717)
StreamTableScan { table: intraday_position_values_mv_next, columns: [account_group_id, asset_id, position_type, group_currency, purchased_quantity, market_value_group, average_cost_group, fair_value_group, accrued_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, market_value_asset, average_cost_asset, fair_value_asset, change_time, account_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, holding_currency, intraday_fx_rates_latest_mv_next.target_currency_code, asset_currency] }
├── output:
│   ┌── intraday_position_values_mv_next.account_group_id
│   ├── intraday_position_values_mv_next.asset_id
│   ├── intraday_position_values_mv_next.position_type
│   ├── intraday_position_values_mv_next.group_currency
│   ├── intraday_position_values_mv_next.purchased_quantity
│   ├── intraday_position_values_mv_next.market_value_group
│   ├── intraday_position_values_mv_next.average_cost_group
│   ├── intraday_position_values_mv_next.fair_value_group
│   ├── intraday_position_values_mv_next.accrued_value_group
│   ├── intraday_position_values_mv_next.market_value_system
│   ├── intraday_position_values_mv_next.average_cost_system
│   ├── intraday_position_values_mv_next.fair_value_system
│   ├── intraday_position_values_mv_next.accrued_value_system
│   ├── intraday_position_values_mv_next.market_value_asset
│   ├── intraday_position_values_mv_next.average_cost_asset
│   ├── intraday_position_values_mv_next.fair_value_asset
│   ├── intraday_position_values_mv_next.change_time
│   ├── intraday_position_values_mv_next.account_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#1
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date#1
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Int32
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#2
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#3
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#4
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.$src
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_group_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
│   ├── intraday_position_values_mv_next.$src
│   ├── intraday_position_values_mv_next.holding_currency
│   ├── intraday_position_values_mv_next.intraday_fx_rates_latest_mv_next.target_currency_code
│   └── intraday_position_values_mv_next.asset_currency
├── stream key:
│   ┌── intraday_position_values_mv_next.account_id
│   ├── intraday_position_values_mv_next.asset_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#1
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Date#1
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Int32
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#2
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#3
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.null:Varchar#4
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.$src
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_group_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
│   ├── intraday_position_values_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
│   ├── intraday_position_values_mv_next.$src
│   ├── intraday_position_values_mv_next.holding_currency
│   ├── intraday_position_values_mv_next.group_currency
│   ├── intraday_position_values_mv_next.intraday_fx_rates_latest_mv_next.target_currency_code
│   └── intraday_position_values_mv_next.asset_currency
├── Upstream { output: [ account_group_id, asset_id, position_type, group_currency, purchased_quantity, market_value_group, average_cost_group, fair_value_group, accrued_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, market_value_asset, average_cost_asset, fair_value_asset, change_time, account_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, holding_currency, intraday_fx_rates_latest_mv_next.target_currency_code, asset_currency ], stream key: [] }
└── BatchPlanNode { output: [ account_group_id, asset_id, position_type, group_currency, purchased_quantity, market_value_group, average_cost_group, fair_value_group, accrued_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, market_value_asset, average_cost_asset, fair_value_asset, change_time, account_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, holding_currency, intraday_fx_rates_latest_mv_next.target_currency_code, asset_currency ], stream key: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
