position_summary_mv · explain

← cluster insights objects position_summary_mv explain
Overview Objects Graph History
materialized view · insights.position_summary_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Aggregation state — unbounded unless keyed or temporally filtered
Heat tree Operator graph
9 operators
Materialize · insights.position_summary_mv
0% idle 2 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 · 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.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 61616 (Actor 739606,739605)
StreamMaterialize { columns: [account_group_id, source_entity_type, dim_balance_date, position_type, currency_code, market_value, total_average_cost, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system_currency, total_average_cost_system_currency, fair_value_system_currency, accrued_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency], stream_key: [account_group_id, source_entity_type, dim_balance_date, currency_code, position_type], pk_columns: [account_group_id, source_entity_type, dim_balance_date, currency_code, position_type], pk_conflict: NoCheck }
├── output: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.position_type, position_asset_values_mv_next.group_currency, sum(position_asset_values_mv_next.market_value), sum(position_asset_values_mv_next.average_cost), sum(position_asset_values_mv_next.fair_value), sum(position_asset_values_mv_next.accrued_value), sum(position_asset_values_mv_next.relationship_value), sum(position_asset_values_mv_next.fair_relationship_value), sum(position_asset_values_mv_next.market_value_system), sum(position_asset_values_mv_next.average_cost_system), sum(position_asset_values_mv_next.fair_value_system), sum(position_asset_values_mv_next.accrued_value_system), sum(position_asset_values_mv_next.relationship_value_system), sum(position_asset_values_mv_next.fair_relationship_value_system) ]
├── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_type ]
└── StreamProject { exprs: [position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.position_type, position_asset_values_mv_next.group_currency, sum(position_asset_values_mv_next.market_value), sum(position_asset_values_mv_next.average_cost), sum(position_asset_values_mv_next.fair_value), sum(position_asset_values_mv_next.accrued_value), sum(position_asset_values_mv_next.relationship_value), sum(position_asset_values_mv_next.fair_relationship_value), sum(position_asset_values_mv_next.market_value_system), sum(position_asset_values_mv_next.average_cost_system), sum(position_asset_values_mv_next.fair_value_system), sum(position_asset_values_mv_next.accrued_value_system), sum(position_asset_values_mv_next.relationship_value_system), sum(position_asset_values_mv_next.fair_relationship_value_system)] }
    ├── output: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.position_type, position_asset_values_mv_next.group_currency, sum(position_asset_values_mv_next.market_value), sum(position_asset_values_mv_next.average_cost), sum(position_asset_values_mv_next.fair_value), sum(position_asset_values_mv_next.accrued_value), sum(position_asset_values_mv_next.relationship_value), sum(position_asset_values_mv_next.fair_relationship_value), sum(position_asset_values_mv_next.market_value_system), sum(position_asset_values_mv_next.average_cost_system), sum(position_asset_values_mv_next.fair_value_system), sum(position_asset_values_mv_next.accrued_value_system), sum(position_asset_values_mv_next.relationship_value_system), sum(position_asset_values_mv_next.fair_relationship_value_system) ]
    ├── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_type ]
    └── StreamHashAgg { group_key: [position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_type], aggs: [sum(position_asset_values_mv_next.market_value), sum(position_asset_values_mv_next.average_cost), sum(position_asset_values_mv_next.fair_value), sum(position_asset_values_mv_next.accrued_value), sum(position_asset_values_mv_next.relationship_value), sum(position_asset_values_mv_next.fair_relationship_value), sum(position_asset_values_mv_next.market_value_system), sum(position_asset_values_mv_next.average_cost_system), sum(position_asset_values_mv_next.fair_value_system), sum(position_asset_values_mv_next.accrued_value_system), sum(position_asset_values_mv_next.relationship_value_system), sum(position_asset_values_mv_next.fair_relationship_value_system), count] }
        ├── output: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_type, sum(position_asset_values_mv_next.market_value), sum(position_asset_values_mv_next.average_cost), sum(position_asset_values_mv_next.fair_value), sum(position_asset_values_mv_next.accrued_value), sum(position_asset_values_mv_next.relationship_value), sum(position_asset_values_mv_next.fair_relationship_value), sum(position_asset_values_mv_next.market_value_system), sum(position_asset_values_mv_next.average_cost_system), sum(position_asset_values_mv_next.fair_value_system), sum(position_asset_values_mv_next.accrued_value_system), sum(position_asset_values_mv_next.relationship_value_system), sum(position_asset_values_mv_next.fair_relationship_value_system), count ]
        ├── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_type ]
        └── StreamLocalityProvider { locality_columns: [position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_type] }
            ├── output:
            │   ┌── position_asset_values_mv_next.account_group_id
            │   ├── position_asset_values_mv_next.source_entity_type
            │   ├── position_asset_values_mv_next.dim_value_date
            │   ├── position_asset_values_mv_next.group_currency
            │   ├── position_asset_values_mv_next.position_type
            │   ├── position_asset_values_mv_next.market_value
            │   ├── position_asset_values_mv_next.average_cost
            │   ├── position_asset_values_mv_next.fair_value
            │   ├── position_asset_values_mv_next.accrued_value
            │   ├── position_asset_values_mv_next.relationship_value
            │   ├── position_asset_values_mv_next.fair_relationship_value
            │   ├── position_asset_values_mv_next.market_value_system
            │   ├── position_asset_values_mv_next.average_cost_system
            │   ├── position_asset_values_mv_next.fair_value_system
            │   ├── position_asset_values_mv_next.accrued_value_system
            │   ├── position_asset_values_mv_next.relationship_value_system
            │   ├── position_asset_values_mv_next.fair_relationship_value_system
            │   ├── position_asset_values_mv_next.asset_id
            │   ├── position_asset_values_mv_next.position_values_mv_next.position_type_expanded
            │   └── position_asset_values_mv_next.flag
            ├── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_type, position_asset_values_mv_next.asset_id, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ]
            └── MergeExecutor
                ├── output:
                │   ┌── position_asset_values_mv_next.account_group_id
                │   ├── position_asset_values_mv_next.source_entity_type
                │   ├── position_asset_values_mv_next.dim_value_date
                │   ├── position_asset_values_mv_next.group_currency
                │   ├── position_asset_values_mv_next.position_type
                │   ├── position_asset_values_mv_next.market_value
                │   ├── position_asset_values_mv_next.average_cost
                │   ├── position_asset_values_mv_next.fair_value
                │   ├── position_asset_values_mv_next.accrued_value
                │   ├── position_asset_values_mv_next.relationship_value
                │   ├── position_asset_values_mv_next.fair_relationship_value
                │   ├── position_asset_values_mv_next.market_value_system
                │   ├── position_asset_values_mv_next.average_cost_system
                │   ├── position_asset_values_mv_next.fair_value_system
                │   ├── position_asset_values_mv_next.accrued_value_system
                │   ├── position_asset_values_mv_next.relationship_value_system
                │   ├── position_asset_values_mv_next.fair_relationship_value_system
                │   ├── position_asset_values_mv_next.asset_id
                │   ├── position_asset_values_mv_next.position_values_mv_next.position_type_expanded
                │   └── position_asset_values_mv_next.flag
                └── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.asset_id, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ]

Fragment 61617 (Actor 739629,739630)
StreamTableScan { table: position_asset_values_mv_next, columns: [account_group_id, source_entity_type, dim_value_date, group_currency, position_type, market_value, average_cost, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system, average_cost_system, fair_value_system, accrued_value_system, relationship_value_system, fair_relationship_value_system, asset_id, position_values_mv_next.position_type_expanded, flag] }
├── output:
│   ┌── position_asset_values_mv_next.account_group_id
│   ├── position_asset_values_mv_next.source_entity_type
│   ├── position_asset_values_mv_next.dim_value_date
│   ├── position_asset_values_mv_next.group_currency
│   ├── position_asset_values_mv_next.position_type
│   ├── position_asset_values_mv_next.market_value
│   ├── position_asset_values_mv_next.average_cost
│   ├── position_asset_values_mv_next.fair_value
│   ├── position_asset_values_mv_next.accrued_value
│   ├── position_asset_values_mv_next.relationship_value
│   ├── position_asset_values_mv_next.fair_relationship_value
│   ├── position_asset_values_mv_next.market_value_system
│   ├── position_asset_values_mv_next.average_cost_system
│   ├── position_asset_values_mv_next.fair_value_system
│   ├── position_asset_values_mv_next.accrued_value_system
│   ├── position_asset_values_mv_next.relationship_value_system
│   ├── position_asset_values_mv_next.fair_relationship_value_system
│   ├── position_asset_values_mv_next.asset_id
│   ├── position_asset_values_mv_next.position_values_mv_next.position_type_expanded
│   └── position_asset_values_mv_next.flag
├── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.asset_id, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ]
├── Upstream { output: [ account_group_id, source_entity_type, dim_value_date, group_currency, position_type, market_value, average_cost, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system, average_cost_system, fair_value_system, accrued_value_system, relationship_value_system, fair_relationship_value_system, asset_id, position_values_mv_next.position_type_expanded, flag ], stream key: [] }
└── BatchPlanNode { output: [ account_group_id, source_entity_type, dim_value_date, group_currency, position_type, market_value, average_cost, fair_value, accrued_value, relationship_value, fair_relationship_value, market_value_system, average_cost_system, fair_value_system, accrued_value_system, relationship_value_system, fair_relationship_value_system, asset_id, position_values_mv_next.position_type_expanded, flag ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
