position_by_currency_mv · explain

← cluster insights objects position_by_currency_mv explain
materialized view · insights.position_by_currency_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filtered
Heat tree Operator graph
28 operators
Materialize · insights.position_by_currency_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · position_values_mv_next.account_group_id_expanded = positio…
— — 2 actors
HashJoin · Inner · position_values_mv_next.account_group_id_expanded = positio… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · position_summary_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Expand · position_values_mv_next
0% idle 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 64266 (Actor 747233,747232)
StreamMaterialize { columns: [account_group_id, source_entity_type, dim_balance_date, position_type, item_id, currency_code, market_value, total_average_cost, fair_value, accrued_value, market_value_system_currency, total_average_cost_system_currency, fair_value_system_currency, accrued_value_system_currency, weight, fair_value_weight, position_values_mv_next.position_type_expanded(hidden), flag(hidden), position_summary_mv_next.source_entity_type(hidden)], stream_key: [account_group_id, dim_balance_date, position_type, currency_code, source_entity_type, position_values_mv_next.position_type_expanded, item_id, flag, position_summary_mv_next.source_entity_type], pk_columns: [account_group_id, dim_balance_date, position_type, currency_code, source_entity_type, position_values_mv_next.position_type_expanded, item_id, flag, position_summary_mv_next.source_entity_type], pk_conflict: NoCheck }
├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), $expr2, $expr3, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type ]
├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, flag, position_summary_mv_next.source_entity_type ]
└── StreamProject { exprs: [position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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.market_value_system) / Case((position_summary_mv_next.market_value_system_currency = 0:Decimal), null:Decimal, position_summary_mv_next.market_value_system_currency)) as $expr2, (sum(position_values_mv_next.fair_value_system) / Case((position_summary_mv_next.fair_value_system_currency = 0:Decimal), null:Decimal, position_summary_mv_next.fair_value_system_currency)) as $expr3, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type] }
    ├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), $expr2, $expr3, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type ]
    ├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, flag, position_summary_mv_next.source_entity_type ]
    └── MergeExecutor
        ├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.source_entity_type ]
        └── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, flag, position_summary_mv_next.source_entity_type ]

Fragment 64267 (Actor 747234,747235)
StreamSyncLogStore
├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.source_entity_type ]
├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, flag, position_summary_mv_next.source_entity_type ]
└── StreamHashJoin { type: Inner, predicate: position_values_mv_next.account_group_id_expanded = position_summary_mv_next.account_group_id AND position_values_mv_next.dim_value_date_expanded = position_summary_mv_next.dim_balance_date AND $expr1 = position_summary_mv_next.position_type AND position_values_mv_next.group_currency_expanded = position_summary_mv_next.currency_code }
    ├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.source_entity_type ]
    ├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, flag, position_summary_mv_next.source_entity_type ]
    ├── MergeExecutor { output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), position_values_mv_next.position_type_expanded, flag ], stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, flag ] }
    └── MergeExecutor { output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.source_entity_type ], stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.source_entity_type ] }

Fragment 64268 (Actor 746703,746704)
StreamLocalityProvider { locality_columns: [position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded] }
├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), position_values_mv_next.position_type_expanded, flag ]
├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.group_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, flag ]
└── MergeExecutor { output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), 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.dim_value_date_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, flag ] }

Fragment 64269 (Actor 746721,746722)
StreamProject { exprs: [position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, Coalesce(position_values_mv_next.position_type_expanded, 'POSITION':Varchar) as $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), 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.dim_value_date_expanded, $expr1, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, 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.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), 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.dim_value_date_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_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.dim_value_date_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_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.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), count] }
    ├── output: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_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.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), count ]
    ├── stream key: [ position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_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.dim_value_date_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, flag] }
        ├── output:
        │   ┌── position_values_mv_next.account_group_id_expanded
        │   ├── position_values_mv_next.source_entity_type_expanded
        │   ├── position_values_mv_next.dim_value_date_expanded
        │   ├── position_values_mv_next.position_type_expanded
        │   ├── position_values_mv_next.holding_currency_expanded
        │   ├── position_values_mv_next.group_currency_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.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.account_id_expanded
        │   ├── position_values_mv_next.$expr2_expanded
        │   ├── position_values_mv_next.asset_id_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.dim_value_date
        │   ├── position_values_mv_next.position_type
        │   ├── position_values_mv_next.holding_currency
        │   ├── 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.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.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_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.dim_value_date_expanded
        │   ├── position_values_mv_next.position_type_expanded
        │   ├── position_values_mv_next.holding_currency_expanded
        │   ├── position_values_mv_next.group_currency_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.dim_value_date_expanded
            │   ├── position_values_mv_next.position_type_expanded
            │   ├── position_values_mv_next.holding_currency_expanded
            │   ├── position_values_mv_next.group_currency_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.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.account_id_expanded
            │   ├── position_values_mv_next.$expr2_expanded
            │   ├── position_values_mv_next.asset_id_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.dim_value_date
            │   ├── position_values_mv_next.position_type
            │   ├── position_values_mv_next.holding_currency
            │   ├── 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.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.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_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 64270 (Actor 746733,746734)
StreamExpand { column_subsets: [[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.holding_currency, position_values_mv_next.group_currency], [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.holding_currency, 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.dim_value_date_expanded
│   ├── position_values_mv_next.position_type_expanded
│   ├── position_values_mv_next.holding_currency_expanded
│   ├── position_values_mv_next.group_currency_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.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.account_id_expanded
│   ├── position_values_mv_next.$expr2_expanded
│   ├── position_values_mv_next.asset_id_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.dim_value_date
│   ├── position_values_mv_next.position_type
│   ├── position_values_mv_next.holding_currency
│   ├── 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.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.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_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
└── StreamTableScan
├─table: position_values_mv_next
└─columns:
  ┌─account_group_id
  ├─source_entity_type
  ├─dim_value_date
  ├─position_type
  ├─holding_currency
  ├─group_currency
  ├─market_value_group
  ├─average_cost_group
  ├─fair_value_group
  ├─accrued_value_group
  ├─market_value_system
  ├─average_cost_system
  ├─fair_value_system
  ├─accrued_value_system
  ├─account_id
  ├─$expr2
  ├─asset_id
  ├─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.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.holding_currency
    │   ├── 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.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.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_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: [ account_group_id, source_entity_type, dim_value_date, position_type, holding_currency, group_currency, market_value_group, average_cost_group, fair_value_group, accrued_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, account_id, $expr2, asset_id, 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: [ account_group_id, source_entity_type, dim_value_date, position_type, holding_currency, group_currency, market_value_group, average_cost_group, fair_value_group, accrued_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, account_id, $expr2, asset_id, 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: [] }

Fragment 64271 (Actor 746888,746887)
StreamLocalityProvider { locality_columns: [position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code] } { output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.source_entity_type ], stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.source_entity_type ] }
└── MergeExecutor { output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.source_entity_type ], stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ] }

Fragment 64272 (Actor 746890,746889)
StreamTableScan { table: position_summary_mv_next, columns: [account_group_id, dim_balance_date, position_type, currency_code, market_value_system_currency, fair_value_system_currency, source_entity_type] } { output: [ position_summary_mv_next.account_group_id, position_summary_mv_next.dim_balance_date, position_summary_mv_next.position_type, position_summary_mv_next.currency_code, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, position_summary_mv_next.source_entity_type ], stream key: [ position_summary_mv_next.account_group_id, position_summary_mv_next.source_entity_type, position_summary_mv_next.dim_balance_date, position_summary_mv_next.currency_code, position_summary_mv_next.position_type ] }
├── Upstream { output: [ account_group_id, dim_balance_date, position_type, currency_code, market_value_system_currency, fair_value_system_currency, source_entity_type ], stream key: [] }
└── BatchPlanNode { output: [ account_group_id, dim_balance_date, position_type, currency_code, market_value_system_currency, fair_value_system_currency, source_entity_type ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
