position_by_asset_mv · explain

← cluster insights objects position_by_asset_mv explain
materialized view · insights.position_by_asset_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
46 operators
Materialize · insights.position_by_asset_mv
0% idle 2 actors
Project
— — 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
Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (positi…
0% idle 2 actors
Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (positi…
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · position_values_mv_next.holding_currency_expanded = foreign…
— — 2 actors
HashJoin · LeftOuter · position_values_mv_next.holding_currency_expanded = foreign… 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
StreamScan · foreign_exchange_rates_eod_ft
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
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 64255 (Actor 747219,747218)
StreamMaterialize { columns: [account_group_id, source_entity_type, dim_balance_date, position_type, asset_id, asset_currency, 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, market_value_asset_currency, total_average_cost_asset_currency, fair_value_asset_currency, quantity, weight, fair_value_weight, position_values_mv_next.holding_currency_expanded(hidden), 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, position_values_mv_next.holding_currency_expanded, asset_currency, source_entity_type, position_values_mv_next.position_type_expanded, asset_id, flag, position_summary_mv_next.source_entity_type], pk_columns: [account_group_id, dim_balance_date, position_type, currency_code, position_values_mv_next.holding_currency_expanded, asset_currency, source_entity_type, position_values_mv_next.position_type_expanded, asset_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.asset_id_expanded, position_values_mv_next.asset_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), $expr3, $expr4, $expr5, sum(position_values_mv_next.purchased_quantity), $expr6, $expr7, position_values_mv_next.holding_currency_expanded, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_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.asset_id_expanded, position_values_mv_next.asset_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_holding) * $expr2) as $expr3, (sum(position_values_mv_next.average_cost_holding) * $expr2) as $expr4, (sum(position_values_mv_next.fair_value_holding) * $expr2) as $expr5, sum(position_values_mv_next.purchased_quantity), (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 $expr6, (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 $expr7, position_values_mv_next.holding_currency_expanded, 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.asset_id_expanded, position_values_mv_next.asset_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), $expr3, $expr4, $expr5, sum(position_values_mv_next.purchased_quantity), $expr6, $expr7, position_values_mv_next.holding_currency_expanded, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, Coalesce(foreign_exchange_rates_eod_ft.rate, Case((position_values_mv_next.holding_currency_expanded = position_values_mv_next.asset_currency_expanded), 1:Int32, null:Int32)::Decimal) as $expr2, 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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, position_summary_mv_next.market_value_system_currency, position_summary_mv_next.fair_value_system_currency, $expr2, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, flag, position_summary_mv_next.source_entity_type ]

Fragment 64256 (Actor 747217,747216)
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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_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 64257 (Actor 747220,747221)
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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, 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.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, position_values_mv_next.position_type_expanded, flag ], stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_currency_expanded, flag ] }

Fragment 64258 (Actor 747224,747225)
StreamFilter { predicate: (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (position_values_mv_next.holding_currency_expanded = position_values_mv_next.asset_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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, position_values_mv_next.position_type_expanded, flag ]
├── stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_currency_expanded, flag ]
└── 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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, 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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, 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_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.rate, position_values_mv_next.position_type_expanded, flag ]
    ├── stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_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, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ]
        └── stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_currency_expanded, flag ]

Fragment 64259 (Actor 747222,747223)
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, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ]
├── stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_currency_expanded, flag ]
└── StreamHashJoin { type: LeftOuter, predicate: position_values_mv_next.holding_currency_expanded = foreign_exchange_rates_eod_ft.source_currency_code AND position_values_mv_next.asset_currency_expanded = foreign_exchange_rates_eod_ft.target_currency_code AND position_values_mv_next.dim_value_date_expanded = foreign_exchange_rates_eod_ft.date }
    ├── 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.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ]
    ├── stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_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, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity) ], stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_currency_expanded, flag ] }
    └── MergeExecutor { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }

Fragment 64260 (Actor 747341,747342)
StreamLocalityProvider { locality_columns: [position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_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, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity) ]
├── stream key: [ position_values_mv_next.holding_currency_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.dim_value_date_expanded, position_values_mv_next.account_group_id_expanded, position_values_mv_next.source_entity_type_expanded, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.group_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, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity) ], 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.asset_id_expanded, position_values_mv_next.asset_currency_expanded, position_values_mv_next.holding_currency_expanded, position_values_mv_next.group_currency_expanded, flag ] }

Fragment 64261 (Actor 747344,747343)
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, position_values_mv_next.position_type_expanded, position_values_mv_next.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity)] }
├── 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.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity) ]
├── 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.asset_id_expanded, position_values_mv_next.asset_currency_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.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), 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.asset_id_expanded, position_values_mv_next.asset_currency_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), sum(position_values_mv_next.market_value_holding), sum(position_values_mv_next.average_cost_holding), sum(position_values_mv_next.fair_value_holding), sum(position_values_mv_next.purchased_quantity), 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.asset_id_expanded, position_values_mv_next.asset_currency_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.asset_id_expanded, position_values_mv_next.asset_currency_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.asset_id_expanded
        │   ├── position_values_mv_next.asset_currency_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.market_value_holding_expanded
        │   ├── position_values_mv_next.average_cost_holding_expanded
        │   ├── position_values_mv_next.fair_value_holding_expanded
        │   ├── position_values_mv_next.purchased_quantity_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.dim_value_date
        │   ├── position_values_mv_next.position_type
        │   ├── position_values_mv_next.asset_id
        │   ├── position_values_mv_next.asset_currency
        │   ├── 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.market_value_holding
        │   ├── position_values_mv_next.average_cost_holding
        │   ├── position_values_mv_next.fair_value_holding
        │   ├── position_values_mv_next.purchased_quantity
        │   ├── 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.dim_value_date_expanded
        │   ├── position_values_mv_next.position_type_expanded
        │   ├── position_values_mv_next.asset_id_expanded
        │   ├── position_values_mv_next.asset_currency_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.asset_id_expanded
            │   ├── position_values_mv_next.asset_currency_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.market_value_holding_expanded
            │   ├── position_values_mv_next.average_cost_holding_expanded
            │   ├── position_values_mv_next.fair_value_holding_expanded
            │   ├── position_values_mv_next.purchased_quantity_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.dim_value_date
            │   ├── position_values_mv_next.position_type
            │   ├── position_values_mv_next.asset_id
            │   ├── position_values_mv_next.asset_currency
            │   ├── 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.market_value_holding
            │   ├── position_values_mv_next.average_cost_holding
            │   ├── position_values_mv_next.fair_value_holding
            │   ├── position_values_mv_next.purchased_quantity
            │   ├── 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 64262 (Actor 747347,747348)
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.asset_id, position_values_mv_next.asset_currency, 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.asset_id, position_values_mv_next.asset_currency, 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.asset_id_expanded
│   ├── position_values_mv_next.asset_currency_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.market_value_holding_expanded
│   ├── position_values_mv_next.average_cost_holding_expanded
│   ├── position_values_mv_next.fair_value_holding_expanded
│   ├── position_values_mv_next.purchased_quantity_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.dim_value_date
│   ├── position_values_mv_next.position_type
│   ├── position_values_mv_next.asset_id
│   ├── position_values_mv_next.asset_currency
│   ├── 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.market_value_holding
│   ├── position_values_mv_next.average_cost_holding
│   ├── position_values_mv_next.fair_value_holding
│   ├── position_values_mv_next.purchased_quantity
│   ├── 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.dim_value_date
  ├─position_values_mv_next.position_type
  ├─position_values_mv_next.asset_id
  ├─position_values_mv_next.asset_currency
  ├─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.market_value_holding
  ├─position_values_mv_next.average_cost_holding
  ├─position_values_mv_next.fair_value_holding
  ├─position_values_mv_next.purchased_quantity
  ├─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.dim_value_date, position_values_mv_next.position_type, position_values_mv_next.asset_id, position_values_mv_next.asset_currency, 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.market_value_holding, position_values_mv_next.average_cost_holding, position_values_mv_next.fair_value_holding, position_values_mv_next.purchased_quantity, 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
  ├─holding_currency
  ├─group_currency
  ├─asset_currency
  ├─market_value_holding
  ├─average_cost_holding
  ├─purchased_quantity
  ├─fair_value_holding
  ├─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
  ├─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.holding_currency, position_values_mv_next.group_currency, position_values_mv_next.asset_currency, position_values_mv_next.market_value_holding, position_values_mv_next.average_cost_holding, position_values_mv_next.purchased_quantity, position_values_mv_next.fair_value_holding, 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.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, holding_currency, group_currency, asset_currency, market_value_holding, average_cost_holding, purchased_quantity, fair_value_holding, 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, 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, holding_currency, group_currency, asset_currency, market_value_holding, average_cost_holding, purchased_quantity, fair_value_holding, 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, 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 64263 (Actor 747349,747350)
StreamTableScan { table: foreign_exchange_rates_eod_ft, columns: [source_currency_code, target_currency_code, date, rate] } { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }
├── Upstream { output: [ source_currency_code, target_currency_code, date, rate ], stream key: [] }
└── BatchPlanNode { output: [ source_currency_code, target_currency_code, date, rate ], stream key: [] }

Fragment 64264 (Actor 747346,747345)
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 64265 (Actor 747329,747330)
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
