position_asset_values_mv · explain

← cluster insights objects position_asset_values_mv explain
Overview Objects Graph History
materialized view · insights.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
11 operators
Materialize · insights.position_asset_values_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
Expand · position_values_mv_next
0% idle 2 actors
Project · position_values_mv_next
— — 2 actors
StreamScan · 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 63961 (Actor 745287,745286)
StreamMaterialize { columns: [account_group_id, source_entity_type, asset_id, 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, position_values_mv_next.position_type_expanded(hidden), flag(hidden)], stream_key: [account_group_id, source_entity_type, asset_id, dim_value_date, group_currency, position_values_mv_next.position_type_expanded, flag], pk_columns: [account_group_id, source_entity_type, asset_id, dim_value_date, group_currency, position_values_mv_next.position_type_expanded, flag], pk_conflict: NoCheck }
├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, $expr1, sum(position_values_mv_next.market_value_group), sum(position_values_mv_next.average_cost_group), sum(position_values_mv_next.fair_value_group), sum(position_values_mv_next.accrued_value_group), sum(position_values_mv_next.relationship_value_group), sum(position_values_mv_next.fair_relationship_value_group), sum(position_values_mv_next.market_value_system), sum(position_values_mv_next.average_cost_system), sum(position_values_mv_next.fair_value_system), sum(position_values_mv_next.accrued_value_system), sum(position_values_mv_next.relationship_value_system), sum(position_values_mv_next.fair_relationship_value_system), position_values_mv_next.position_type_expanded, flag ]
├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, position_values_mv_next.position_type_expanded, flag ]
└── StreamProject { exprs: [position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, Coalesce(position_values_mv_next.position_type_expanded, 'POSITION':Varchar) as $expr1, sum(position_values_mv_next.market_value_group), sum(position_values_mv_next.average_cost_group), sum(position_values_mv_next.fair_value_group), sum(position_values_mv_next.accrued_value_group), sum(position_values_mv_next.relationship_value_group), sum(position_values_mv_next.fair_relationship_value_group), sum(position_values_mv_next.market_value_system), sum(position_values_mv_next.average_cost_system), sum(position_values_mv_next.fair_value_system), sum(position_values_mv_next.accrued_value_system), sum(position_values_mv_next.relationship_value_system), sum(position_values_mv_next.fair_relationship_value_system), position_values_mv_next.position_type_expanded, flag] }
    ├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, $expr1, sum(position_values_mv_next.market_value_group), sum(position_values_mv_next.average_cost_group), sum(position_values_mv_next.fair_value_group), sum(position_values_mv_next.accrued_value_group), sum(position_values_mv_next.relationship_value_group), sum(position_values_mv_next.fair_relationship_value_group), sum(position_values_mv_next.market_value_system), sum(position_values_mv_next.average_cost_system), sum(position_values_mv_next.fair_value_system), sum(position_values_mv_next.accrued_value_system), sum(position_values_mv_next.relationship_value_system), sum(position_values_mv_next.fair_relationship_value_system), position_values_mv_next.position_type_expanded, flag ]
    ├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, position_values_mv_next.position_type_expanded, flag ]
    └── StreamHashAgg { group_key: [position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, position_values_mv_next.position_type_expanded, flag], aggs: [sum(position_values_mv_next.market_value_group), sum(position_values_mv_next.average_cost_group), sum(position_values_mv_next.fair_value_group), sum(position_values_mv_next.accrued_value_group), sum(position_values_mv_next.relationship_value_group), sum(position_values_mv_next.fair_relationship_value_group), sum(position_values_mv_next.market_value_system), sum(position_values_mv_next.average_cost_system), sum(position_values_mv_next.fair_value_system), sum(position_values_mv_next.accrued_value_system), sum(position_values_mv_next.relationship_value_system), sum(position_values_mv_next.fair_relationship_value_system), count] }
        ├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, position_values_mv_next.position_type_expanded, flag, sum(position_values_mv_next.market_value_group), sum(position_values_mv_next.average_cost_group), sum(position_values_mv_next.fair_value_group), sum(position_values_mv_next.accrued_value_group), sum(position_values_mv_next.relationship_value_group), sum(position_values_mv_next.fair_relationship_value_group), sum(position_values_mv_next.market_value_system), sum(position_values_mv_next.average_cost_system), sum(position_values_mv_next.fair_value_system), sum(position_values_mv_next.accrued_value_system), sum(position_values_mv_next.relationship_value_system), sum(position_values_mv_next.fair_relationship_value_system), count ]
        ├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, position_values_mv_next.position_type_expanded, flag ]
        └── StreamLocalityProvider { locality_columns: [position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.group_currency_expanded, position_values_mv_next.position_type_expanded, flag] }
            ├── output:
            │   ┌── position_values_mv_next.account_group_id_expanded
            │   ├── position_values_mv_next.source_entity_type_expanded
            │   ├── position_values_mv_next.asset_id_expanded
            │   ├── position_values_mv_next.dim_value_date_expanded
            │   ├── position_values_mv_next.group_currency_expanded
            │   ├── position_values_mv_next.position_type_expanded
            │   ├── position_values_mv_next.market_value_group_expanded
            │   ├── position_values_mv_next.average_cost_group_expanded
            │   ├── position_values_mv_next.fair_value_group_expanded
            │   ├── position_values_mv_next.accrued_value_group_expanded
            │   ├── position_values_mv_next.relationship_value_group_expanded
            │   ├── position_values_mv_next.fair_relationship_value_group_expanded
            │   ├── position_values_mv_next.market_value_system_expanded
            │   ├── position_values_mv_next.average_cost_system_expanded
            │   ├── position_values_mv_next.fair_value_system_expanded
            │   ├── position_values_mv_next.accrued_value_system_expanded
            │   ├── position_values_mv_next.relationship_value_system_expanded
            │   ├── position_values_mv_next.fair_relationship_value_system_expanded
            │   ├── position_values_mv_next.holding_currency_expanded
            │   ├── position_values_mv_next.account_id_expanded
            │   ├── position_values_mv_next.$expr2_expanded
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code_expanded
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date_expanded
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id_expanded
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id_expanded
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type_expanded
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code_expanded
            │   ├── position_values_mv_next.holding_values_mv_next.$src_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1_expanded
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
            │   ├── position_values_mv_next.account_group_id
            │   ├── position_values_mv_next.source_entity_type
            │   ├── position_values_mv_next.asset_id
            │   ├── position_values_mv_next.dim_value_date
            │   ├── position_values_mv_next.group_currency
            │   ├── position_values_mv_next.position_type
            │   ├── position_values_mv_next.market_value_group
            │   ├── position_values_mv_next.average_cost_group
            │   ├── position_values_mv_next.fair_value_group
            │   ├── position_values_mv_next.accrued_value_group
            │   ├── position_values_mv_next.relationship_value_group
            │   ├── position_values_mv_next.fair_relationship_value_group
            │   ├── position_values_mv_next.market_value_system
            │   ├── position_values_mv_next.average_cost_system
            │   ├── position_values_mv_next.fair_value_system
            │   ├── position_values_mv_next.accrued_value_system
            │   ├── position_values_mv_next.relationship_value_system
            │   ├── position_values_mv_next.fair_relationship_value_system
            │   ├── position_values_mv_next.holding_currency
            │   ├── position_values_mv_next.account_id
            │   ├── position_values_mv_next.$expr2
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
            │   ├── position_values_mv_next.holding_values_mv_next.$src
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
            │   └── flag
            ├── stream key:
            │   ┌── position_values_mv_next.account_group_id_expanded
            │   ├── position_values_mv_next.source_entity_type_expanded
            │   ├── position_values_mv_next.asset_id_expanded
            │   ├── position_values_mv_next.dim_value_date_expanded
            │   ├── position_values_mv_next.group_currency_expanded
            │   ├── position_values_mv_next.position_type_expanded
            │   ├── flag
            │   ├── position_values_mv_next.holding_currency
            │   ├── position_values_mv_next.group_currency
            │   ├── position_values_mv_next.dim_value_date
            │   ├── position_values_mv_next.account_id
            │   ├── position_values_mv_next.$expr2
            │   ├── position_values_mv_next.asset_id
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type
            │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
            │   ├── position_values_mv_next.holding_values_mv_next.$src
            │   ├── position_values_mv_next.account_group_id
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
            │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
            │   └── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
            └── MergeExecutor
                ├── output:
                │   ┌── position_values_mv_next.account_group_id_expanded
                │   ├── position_values_mv_next.source_entity_type_expanded
                │   ├── position_values_mv_next.asset_id_expanded
                │   ├── position_values_mv_next.dim_value_date_expanded
                │   ├── position_values_mv_next.group_currency_expanded
                │   ├── position_values_mv_next.position_type_expanded
                │   ├── position_values_mv_next.market_value_group_expanded
                │   ├── position_values_mv_next.average_cost_group_expanded
                │   ├── position_values_mv_next.fair_value_group_expanded
                │   ├── position_values_mv_next.accrued_value_group_expanded
                │   ├── position_values_mv_next.relationship_value_group_expanded
                │   ├── position_values_mv_next.fair_relationship_value_group_expanded
                │   ├── position_values_mv_next.market_value_system_expanded
                │   ├── position_values_mv_next.average_cost_system_expanded
                │   ├── position_values_mv_next.fair_value_system_expanded
                │   ├── position_values_mv_next.accrued_value_system_expanded
                │   ├── position_values_mv_next.relationship_value_system_expanded
                │   ├── position_values_mv_next.fair_relationship_value_system_expanded
                │   ├── position_values_mv_next.holding_currency_expanded
                │   ├── position_values_mv_next.account_id_expanded
                │   ├── position_values_mv_next.$expr2_expanded
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code_expanded
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date_expanded
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id_expanded
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id_expanded
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type_expanded
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code_expanded
                │   ├── position_values_mv_next.holding_values_mv_next.$src_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1_expanded
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
                │   ├── position_values_mv_next.account_group_id
                │   ├── position_values_mv_next.source_entity_type
                │   ├── position_values_mv_next.asset_id
                │   ├── position_values_mv_next.dim_value_date
                │   ├── position_values_mv_next.group_currency
                │   ├── position_values_mv_next.position_type
                │   ├── position_values_mv_next.market_value_group
                │   ├── position_values_mv_next.average_cost_group
                │   ├── position_values_mv_next.fair_value_group
                │   ├── position_values_mv_next.accrued_value_group
                │   ├── position_values_mv_next.relationship_value_group
                │   ├── position_values_mv_next.fair_relationship_value_group
                │   ├── position_values_mv_next.market_value_system
                │   ├── position_values_mv_next.average_cost_system
                │   ├── position_values_mv_next.fair_value_system
                │   ├── position_values_mv_next.accrued_value_system
                │   ├── position_values_mv_next.relationship_value_system
                │   ├── position_values_mv_next.fair_relationship_value_system
                │   ├── position_values_mv_next.holding_currency
                │   ├── position_values_mv_next.account_id
                │   ├── position_values_mv_next.$expr2
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type
                │   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                │   ├── position_values_mv_next.holding_values_mv_next.$src
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
                │   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
                │   └── flag
                └── stream key:
                    ┌── position_values_mv_next.holding_currency
                    ├── position_values_mv_next.group_currency
                    ├── position_values_mv_next.dim_value_date
                    ├── position_values_mv_next.account_id
                    ├── position_values_mv_next.$expr2
                    ├── position_values_mv_next.asset_id
                    ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
                    ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
                    ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
                    ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
                    ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type
                    ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                    ├── position_values_mv_next.holding_values_mv_next.$src
                    ├── position_values_mv_next.account_group_id
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
                    ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
                    └── flag

Fragment 63962 (Actor 745334,745335)
StreamExpand { column_subsets: [[position_values_mv_next.account_group_id, position_values_mv_next.source_entity_type, position_values_mv_next.asset_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, position_values_mv_next.position_type], [position_values_mv_next.account_group_id, position_values_mv_next.source_entity_type, position_values_mv_next.asset_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency]] }
├── output:
│   ┌── position_values_mv_next.account_group_id_expanded
│   ├── position_values_mv_next.source_entity_type_expanded
│   ├── position_values_mv_next.asset_id_expanded
│   ├── position_values_mv_next.dim_value_date_expanded
│   ├── position_values_mv_next.group_currency_expanded
│   ├── position_values_mv_next.position_type_expanded
│   ├── position_values_mv_next.market_value_group_expanded
│   ├── position_values_mv_next.average_cost_group_expanded
│   ├── position_values_mv_next.fair_value_group_expanded
│   ├── position_values_mv_next.accrued_value_group_expanded
│   ├── position_values_mv_next.relationship_value_group_expanded
│   ├── position_values_mv_next.fair_relationship_value_group_expanded
│   ├── position_values_mv_next.market_value_system_expanded
│   ├── position_values_mv_next.average_cost_system_expanded
│   ├── position_values_mv_next.fair_value_system_expanded
│   ├── position_values_mv_next.accrued_value_system_expanded
│   ├── position_values_mv_next.relationship_value_system_expanded
│   ├── position_values_mv_next.fair_relationship_value_system_expanded
│   ├── position_values_mv_next.holding_currency_expanded
│   ├── position_values_mv_next.account_id_expanded
│   ├── position_values_mv_next.$expr2_expanded
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code_expanded
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date_expanded
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id_expanded
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id_expanded
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type_expanded
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code_expanded
│   ├── position_values_mv_next.holding_values_mv_next.$src_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1_expanded
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
│   ├── position_values_mv_next.account_group_id
│   ├── position_values_mv_next.source_entity_type
│   ├── position_values_mv_next.asset_id
│   ├── position_values_mv_next.dim_value_date
│   ├── position_values_mv_next.group_currency
│   ├── position_values_mv_next.position_type
│   ├── position_values_mv_next.market_value_group
│   ├── position_values_mv_next.average_cost_group
│   ├── position_values_mv_next.fair_value_group
│   ├── position_values_mv_next.accrued_value_group
│   ├── position_values_mv_next.relationship_value_group
│   ├── position_values_mv_next.fair_relationship_value_group
│   ├── position_values_mv_next.market_value_system
│   ├── position_values_mv_next.average_cost_system
│   ├── position_values_mv_next.fair_value_system
│   ├── position_values_mv_next.accrued_value_system
│   ├── position_values_mv_next.relationship_value_system
│   ├── position_values_mv_next.fair_relationship_value_system
│   ├── position_values_mv_next.holding_currency
│   ├── position_values_mv_next.account_id
│   ├── position_values_mv_next.$expr2
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type
│   ├── position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│   ├── position_values_mv_next.holding_values_mv_next.$src
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
│   ├── position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
│   └── flag
├── stream key: [ position_values_mv_next.holding_currency, position_values_mv_next.group_currency, position_values_mv_next.dim_value_date, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv_next.$src, position_values_mv_next.account_group_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flag ]
└── StreamProject
└─exprs:
  ┌─position_values_mv_next.account_group_id
  ├─position_values_mv_next.source_entity_type
  ├─position_values_mv_next.asset_id
  ├─position_values_mv_next.dim_value_date
  ├─position_values_mv_next.group_currency
  ├─position_values_mv_next.position_type
  ├─position_values_mv_next.market_value_group
  ├─position_values_mv_next.average_cost_group
  ├─position_values_mv_next.fair_value_group
  ├─position_values_mv_next.accrued_value_group
  ├─position_values_mv_next.relationship_value_group
  ├─position_values_mv_next.fair_relationship_value_group
  ├─position_values_mv_next.market_value_system
  ├─position_values_mv_next.average_cost_system
  ├─position_values_mv_next.fair_value_system
  ├─position_values_mv_next.accrued_value_system
  ├─position_values_mv_next.relationship_value_system
  ├─position_values_mv_next.fair_relationship_value_system
  ├─position_values_mv_next.holding_currency
  ├─position_values_mv_next.account_id
  ├─position_values_mv_next.$expr2
  ├─position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
  ├─position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
  ├─position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
  ├─position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
  ├─position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type
  ├─position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─position_values_mv_next.holding_values_mv_next.$src
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
  ├─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  └─position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
    ├── output: [ position_values_mv_next.account_group_id, position_values_mv_next.source_entity_type, position_values_mv_next.asset_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, position_values_mv_next.position_type, position_values_mv_next.market_value_group, position_values_mv_next.average_cost_group, position_values_mv_next.fair_value_group, position_values_mv_next.accrued_value_group, position_values_mv_next.relationship_value_group, position_values_mv_next.fair_relationship_value_group, position_values_mv_next.market_value_system, position_values_mv_next.average_cost_system, position_values_mv_next.fair_value_system, position_values_mv_next.accrued_value_system, position_values_mv_next.relationship_value_system, position_values_mv_next.fair_relationship_value_system, position_values_mv_next.holding_currency, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    ├── stream key: [ position_values_mv_next.holding_currency, position_values_mv_next.group_currency, position_values_mv_next.dim_value_date, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv_next.$src, position_values_mv_next.account_group_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    └── StreamTableScan
├─table: position_values_mv_next
└─columns:
  ┌─asset_id
  ├─account_group_id
  ├─source_entity_type
  ├─dim_value_date
  ├─position_type
  ├─group_currency
  ├─market_value_group
  ├─average_cost_group
  ├─fair_value_group
  ├─accrued_value_group
  ├─relationship_value_group
  ├─fair_relationship_value_group
  ├─market_value_system
  ├─average_cost_system
  ├─fair_value_system
  ├─accrued_value_system
  ├─relationship_value_system
  ├─fair_relationship_value_system
  ├─holding_currency
  ├─account_id
  ├─$expr2
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─holding_values_mv_next.$src
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  └─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
        ├── output: [ position_values_mv_next.asset_id, position_values_mv_next.account_group_id, position_values_mv_next.source_entity_type, position_values_mv_next.dim_value_date, position_values_mv_next.position_type, position_values_mv_next.group_currency, position_values_mv_next.market_value_group, position_values_mv_next.average_cost_group, position_values_mv_next.fair_value_group, position_values_mv_next.accrued_value_group, position_values_mv_next.relationship_value_group, position_values_mv_next.fair_relationship_value_group, position_values_mv_next.market_value_system, position_values_mv_next.average_cost_system, position_values_mv_next.fair_value_system, position_values_mv_next.accrued_value_system, position_values_mv_next.relationship_value_system, position_values_mv_next.fair_relationship_value_system, position_values_mv_next.holding_currency, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
        ├── stream key: [ position_values_mv_next.holding_currency, position_values_mv_next.group_currency, position_values_mv_next.dim_value_date, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv_next.$src, position_values_mv_next.account_group_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
        ├── Upstream { output: [ asset_id, account_group_id, source_entity_type, dim_value_date, position_type, group_currency, market_value_group, average_cost_group, fair_value_group, accrued_value_group, relationship_value_group, fair_relationship_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, relationship_value_system, fair_relationship_value_system, holding_currency, account_id, $expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [] }
        └── BatchPlanNode { output: [ asset_id, account_group_id, source_entity_type, dim_value_date, position_type, group_currency, market_value_group, average_cost_group, fair_value_group, accrued_value_group, relationship_value_group, fair_relationship_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, relationship_value_system, fair_relationship_value_system, holding_currency, account_id, $expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
