RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local

← cluster opportunity objects portfolio_cash_ratio_mv explain
Overview Objects Graph History
materialized view · opportunity.portfolio_cash_ratio_mv profiled over 5s
seconds (1–30)
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredDynamic filter — verify it pairs with a temporal condition to clean state
37 operators
Materialize · opportunity.portfolio_cash_ratio_mv
0% idle 2 actors
Project · (sum(position_values_mv_next.market_value_group) > 0:Decima…
— — 2 actors
Project · (sum(position_values_mv_next.market_value_group) > 0:Decima…
— — 2 actors
Filter · (sum(position_values_mv_next.market_value_group) > 0:Decima…
0% idle 2 actors
Project · (sum(position_values_mv_next.market_value_group) > 0:Decima…
— — 2 actors
HashAgg · (sum(position_values_mv_next.market_value_group) > 0:Decima… Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider · (sum(position_values_mv_next.market_value_group) > 0:Decima…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · position_values_mv_next.account_group_id = portfolio_to_acc…
— — 2 actors
HashJoin · Inner · position_values_mv_next.account_group_id = portfolio_to_acc… 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
Project · portfolio_to_account_groups_mv
— — 2 actors
Filter · portfolio_to_account_groups_mv
0% idle 2 actors
StreamScan · portfolio_to_account_groups_mv
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 · position_values_mv_next
— — 2 actors
DynamicFilter · position_values_mv_next Dynamic filter — verify it pairs with a temporal condition to clean state
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Project
— — 1 actor
Now
0% 2/s 1 actor
Project · position_values_mv_next
— — 2 actors
Filter · position_values_mv_next
2% idle 2 actors
StreamScan · position_values_mv_next
2% 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.
Materialize · opportunity.portfolio_cash_ratio_mv Materialize opportunity.portfolio_c… idle · 2 actors Project · (sum(position_values_mv_next.market_value_group) > 0:Decima… Project (sum(position_values_mv… — · 2 actors Project · (sum(position_values_mv_next.market_value_group) > 0:Decima… Project (sum(position_values_mv… — · 2 actors Filter · (sum(position_values_mv_next.market_value_group) > 0:Decima… Filter (sum(position_values_mv… idle · 2 actors Project · (sum(position_values_mv_next.market_value_group) > 0:Decima… Project (sum(position_values_mv… — · 2 actors HashAgg · (sum(position_values_mv_next.market_value_group) > 0:Decima… HashAgg (sum(position_values_mv… idle · 2 actors LocalityProvider · (sum(position_values_mv_next.market_value_group) > 0:Decima… LocalityProvider (sum(position_values_mv… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · position_values_mv_next.account_group_id = portfolio_to_acc… SyncLogStore Inner · position_values… — · 2 actors HashJoin · Inner · position_values_mv_next.account_group_id = portfolio_to_acc… HashJoin Inner · position_values… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_to_account_groups_mv Project portfolio_to_account_gr… — · 2 actors Filter · portfolio_to_account_groups_mv Filter portfolio_to_account_gr… idle · 2 actors StreamScan · portfolio_to_account_groups_mv StreamScan portfolio_to_account_gr… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · position_values_mv_next Project position_values_mv_next — · 2 actors DynamicFilter · position_values_mv_next DynamicFilter position_values_mv_next idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Project Project — · 1 actor Now Now 2/s · 1 actor Project · position_values_mv_next Project position_values_mv_next — · 2 actors Filter · position_values_mv_next Filter position_values_mv_next idle · 2 actors StreamScan · position_values_mv_next StreamScan position_values_mv_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 61571 (Actor 738782,738783)
StreamMaterialize { columns: [portfolio_id, dim_value_date, currency_code, cash_value, total_value, cash_ratio, activity_name], stream_key: [dim_value_date, currency_code, portfolio_id], pk_columns: [dim_value_date, currency_code, portfolio_id], pk_conflict: NoCheck }
├── output: [ portfolio_to_account_groups_mv.portfolio_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, $expr3, sum(position_values_mv_next.market_value_group), $expr4, 'GET_PORTFOLIO_IDLE_CASH_PERCENTAGE':Varchar ]
├── stream key: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id ]
└── StreamProject { exprs: [portfolio_to_account_groups_mv.portfolio_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, $expr3, sum(position_values_mv_next.market_value_group), ($expr3 / sum(position_values_mv_next.market_value_group)) as $expr4, 'GET_PORTFOLIO_IDLE_CASH_PERCENTAGE':Varchar] }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, $expr3, sum(position_values_mv_next.market_value_group), $expr4, 'GET_PORTFOLIO_IDLE_CASH_PERCENTAGE':Varchar ]
    ├── stream key: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id ]
    └── StreamProject { exprs: [position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id, sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), sum(position_values_mv_next.market_value_group), Coalesce(sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), 0:Decimal) as $expr3] }
        ├── output: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id, sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), sum(position_values_mv_next.market_value_group), $expr3 ]
        ├── stream key: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id ]
        └── StreamFilter { predicate: (sum(position_values_mv_next.market_value_group) > 0:Decimal) }
            ├── output: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id, sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), sum(position_values_mv_next.market_value_group) ]
            ├── stream key: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id ]
            └── StreamProject { exprs: [position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id, sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), sum(position_values_mv_next.market_value_group)] }
                ├── output: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id, sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), sum(position_values_mv_next.market_value_group) ]
                ├── stream key: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id ]
                └── StreamHashAgg { group_key: [position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id], aggs: [sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), sum(position_values_mv_next.market_value_group), count] }
                    ├── output: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id, sum(position_values_mv_next.market_value_group) filter((position_values_mv_next.asset_type = 'CASH':Varchar)), sum(position_values_mv_next.market_value_group), count ]
                    ├── stream key: [ position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id ]
                    └── StreamLocalityProvider { locality_columns: [position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, portfolio_to_account_groups_mv.portfolio_id] }
                        ├── output:
                        │   ┌── position_values_mv_next.dim_value_date
                        │   ├── position_values_mv_next.group_currency
                        │   ├── position_values_mv_next.asset_type
                        │   ├── position_values_mv_next.market_value_group
                        │   ├── portfolio_to_account_groups_mv.portfolio_id
                        │   ├── position_values_mv_next.account_group_id
                        │   ├── position_values_mv_next.holding_currency
                        │   ├── position_values_mv_next.account_id
                        │   ├── position_values_mv_next.$expr2
                        │   ├── position_values_mv_next.asset_id
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                        │   ├── position_values_mv_next.holding_values_mv.$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
                        │   ├── portfolio_to_account_groups_mv.account_group_id
                        │   └── portfolio_to_account_groups_mv.$src
                        ├── stream key:
                        │   ┌── position_values_mv_next.dim_value_date
                        │   ├── position_values_mv_next.group_currency
                        │   ├── portfolio_to_account_groups_mv.portfolio_id
                        │   ├── position_values_mv_next.account_group_id
                        │   ├── position_values_mv_next.holding_currency
                        │   ├── position_values_mv_next.account_id
                        │   ├── position_values_mv_next.$expr2
                        │   ├── position_values_mv_next.asset_id
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
                        │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                        │   ├── position_values_mv_next.holding_values_mv.$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
                        │   └── portfolio_to_account_groups_mv.$src
                        └── MergeExecutor
                            ├── output:
                            │   ┌── position_values_mv_next.dim_value_date
                            │   ├── position_values_mv_next.group_currency
                            │   ├── position_values_mv_next.asset_type
                            │   ├── position_values_mv_next.market_value_group
                            │   ├── portfolio_to_account_groups_mv.portfolio_id
                            │   ├── position_values_mv_next.account_group_id
                            │   ├── position_values_mv_next.holding_currency
                            │   ├── position_values_mv_next.account_id
                            │   ├── position_values_mv_next.$expr2
                            │   ├── position_values_mv_next.asset_id
                            │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
                            │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
                            │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
                            │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
                            │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
                            │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                            │   ├── position_values_mv_next.holding_values_mv.$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
                            │   ├── portfolio_to_account_groups_mv.account_group_id
                            │   └── portfolio_to_account_groups_mv.$src
                            └── stream key:
                                ┌── position_values_mv_next.account_group_id
                                ├── 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.holding_values_with_accruals_mv_next.currency_code
                                ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
                                ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
                                ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
                                ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
                                ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                                ├── position_values_mv_next.holding_values_mv.$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
                                ├── portfolio_to_account_groups_mv.portfolio_id
                                └── portfolio_to_account_groups_mv.$src

Fragment 61572 (Actor 738784,738785)
StreamSyncLogStore
├── output:
│   ┌── position_values_mv_next.dim_value_date
│   ├── position_values_mv_next.group_currency
│   ├── position_values_mv_next.asset_type
│   ├── position_values_mv_next.market_value_group
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_values_mv_next.account_group_id
│   ├── position_values_mv_next.holding_currency
│   ├── position_values_mv_next.account_id
│   ├── position_values_mv_next.$expr2
│   ├── position_values_mv_next.asset_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│   ├── position_values_mv_next.holding_values_mv.$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
│   ├── portfolio_to_account_groups_mv.account_group_id
│   └── portfolio_to_account_groups_mv.$src
├── stream key:
│   ┌── position_values_mv_next.account_group_id
│   ├── 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.holding_values_with_accruals_mv_next.currency_code
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│   ├── position_values_mv_next.holding_values_mv.$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
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   └── portfolio_to_account_groups_mv.$src
└── StreamHashJoin { type: Inner, predicate: position_values_mv_next.account_group_id = portfolio_to_account_groups_mv.account_group_id }
    ├── output:
    │   ┌── position_values_mv_next.dim_value_date
    │   ├── position_values_mv_next.group_currency
    │   ├── position_values_mv_next.asset_type
    │   ├── position_values_mv_next.market_value_group
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── position_values_mv_next.account_group_id
    │   ├── position_values_mv_next.holding_currency
    │   ├── position_values_mv_next.account_id
    │   ├── position_values_mv_next.$expr2
    │   ├── position_values_mv_next.asset_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
    │   ├── position_values_mv_next.holding_values_mv.$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
    │   ├── portfolio_to_account_groups_mv.account_group_id
    │   └── portfolio_to_account_groups_mv.$src
    ├── stream key:
    │   ┌── position_values_mv_next.account_group_id
    │   ├── 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.holding_values_with_accruals_mv_next.currency_code
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
    │   ├── position_values_mv_next.holding_values_mv.$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
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   └── portfolio_to_account_groups_mv.$src
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── position_values_mv_next.account_group_id
    │   │   ├── position_values_mv_next.dim_value_date
    │   │   ├── position_values_mv_next.group_currency
    │   │   ├── position_values_mv_next.asset_type
    │   │   ├── position_values_mv_next.market_value_group
    │   │   ├── position_values_mv_next.holding_currency
    │   │   ├── position_values_mv_next.account_id
    │   │   ├── position_values_mv_next.$expr2
    │   │   ├── position_values_mv_next.asset_id
    │   │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
    │   │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
    │   │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
    │   │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
    │   │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
    │   │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
    │   │   ├── position_values_mv_next.holding_values_mv.$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.account_group_id
    │       ├── 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.holding_values_with_accruals_mv_next.currency_code
    │       ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
    │       ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
    │       ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
    │       ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
    │       ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
    │       ├── position_values_mv_next.holding_values_mv.$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
    └── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 61573 (Actor 738786,738787)
StreamLocalityProvider { locality_columns: [position_values_mv_next.account_group_id] }
├── output:
│   ┌── position_values_mv_next.account_group_id
│   ├── position_values_mv_next.dim_value_date
│   ├── position_values_mv_next.group_currency
│   ├── position_values_mv_next.asset_type
│   ├── position_values_mv_next.market_value_group
│   ├── position_values_mv_next.holding_currency
│   ├── position_values_mv_next.account_id
│   ├── position_values_mv_next.$expr2
│   ├── position_values_mv_next.asset_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│   ├── position_values_mv_next.holding_values_mv.$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.account_group_id
│   ├── 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.holding_values_with_accruals_mv_next.currency_code
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
│   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│   ├── position_values_mv_next.holding_values_mv.$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
└── MergeExecutor
    ├── output:
    │   ┌── position_values_mv_next.account_group_id
    │   ├── position_values_mv_next.dim_value_date
    │   ├── position_values_mv_next.group_currency
    │   ├── position_values_mv_next.asset_type
    │   ├── position_values_mv_next.market_value_group
    │   ├── position_values_mv_next.holding_currency
    │   ├── position_values_mv_next.account_id
    │   ├── position_values_mv_next.$expr2
    │   ├── position_values_mv_next.asset_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
    │   ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
    │   ├── position_values_mv_next.holding_values_mv.$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.holding_values_with_accruals_mv_next.currency_code
        ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
        ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
        ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
        ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
        ├── position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
        ├── position_values_mv_next.holding_values_mv.$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

Fragment 61574 (Actor 738790,738789)
StreamProject
└─exprs:
  ┌─position_values_mv_next.account_group_id
  ├─position_values_mv_next.dim_value_date
  ├─position_values_mv_next.group_currency
  ├─position_values_mv_next.asset_type
  ├─position_values_mv_next.market_value_group
  ├─position_values_mv_next.holding_currency
  ├─position_values_mv_next.account_id
  ├─position_values_mv_next.$expr2
  ├─position_values_mv_next.asset_id
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─position_values_mv_next.holding_values_mv.$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.dim_value_date, position_values_mv_next.group_currency, position_values_mv_next.asset_type, position_values_mv_next.market_value_group, position_values_mv_next.holding_currency, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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 ]
└── StreamDynamicFilter
├─predicate: ($expr1 >= $expr2)
├─output_watermarks: [[$expr1]]
├─output:
│ ┌─position_values_mv_next.account_group_id
│ ├─position_values_mv_next.dim_value_date
│ ├─position_values_mv_next.group_currency
│ ├─position_values_mv_next.asset_type
│ ├─position_values_mv_next.market_value_group
│ ├─$expr1
│ ├─position_values_mv_next.holding_currency
│ ├─position_values_mv_next.account_id
│ ├─position_values_mv_next.$expr2
│ ├─position_values_mv_next.asset_id
│ ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
│ ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
│ ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
│ ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
│ ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
│ ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│ ├─position_values_mv_next.holding_values_mv.$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
└─cleaned_by_watermark: true
    ├── output: [ position_values_mv_next.account_group_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, position_values_mv_next.asset_type, position_values_mv_next.market_value_group, $expr1, position_values_mv_next.holding_currency, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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 ]
    ├── StreamProject
└─exprs:
  ┌─position_values_mv_next.account_group_id
  ├─position_values_mv_next.dim_value_date
  ├─position_values_mv_next.group_currency
  ├─position_values_mv_next.asset_type
  ├─position_values_mv_next.market_value_group
  ├─AtTimeZone(position_values_mv_next.dim_value_date::Timestamp, 'UTC':Varchar) as $expr1
  ├─position_values_mv_next.holding_currency
  ├─position_values_mv_next.account_id
  ├─position_values_mv_next.$expr2
  ├─position_values_mv_next.asset_id
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─position_values_mv_next.holding_values_mv.$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.dim_value_date, position_values_mv_next.group_currency, position_values_mv_next.asset_type, position_values_mv_next.market_value_group, $expr1, position_values_mv_next.holding_currency, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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 ]
    │   └── StreamFilter { predicate: (position_values_mv_next.position_type = 'ASSET':Varchar) }
    │       ├── output: [ position_values_mv_next.account_group_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, position_values_mv_next.asset_type, position_values_mv_next.market_value_group, position_values_mv_next.holding_currency, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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, position_values_mv_next.position_type ]
    │       ├── 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.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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:
  ┌─account_group_id
  ├─dim_value_date
  ├─group_currency
  ├─asset_type
  ├─market_value_group
  ├─holding_currency
  ├─account_id
  ├─$expr2
  ├─asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.account_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─holding_values_mv.$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
  └─position_type
    │           ├── output: [ position_values_mv_next.account_group_id, position_values_mv_next.dim_value_date, position_values_mv_next.group_currency, position_values_mv_next.asset_type, position_values_mv_next.market_value_group, position_values_mv_next.holding_currency, position_values_mv_next.account_id, position_values_mv_next.$expr2, position_values_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$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, position_values_mv_next.position_type ]
    │           ├── 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.holding_values_with_accruals_mv_next.currency_code, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.account_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.asset_id, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.type, position_values_mv_next.holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, position_values_mv_next.holding_values_mv.$src, position_values_mv_next.account_group_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, position_values_mv_next.account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    │           ├── Upstream { output: [ account_group_id, dim_value_date, group_currency, asset_type, market_value_group, holding_currency, account_id, $expr2, asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$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, position_type ], stream key: [] }
    │           └── BatchPlanNode { output: [ account_group_id, dim_value_date, group_currency, asset_type, market_value_group, holding_currency, account_id, $expr2, asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$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, position_type ], stream key: [] }
    └── MergeExecutor { output: [ $expr2 ], stream key: [] }

Fragment 61575 (Actor 738788)
StreamProject { exprs: [SubtractWithTimeZone(now, '30 days':Interval, 'UTC':Varchar) as $expr2], output_watermarks: [[$expr2]] } { output: [ $expr2 ], stream key: [] }
└── StreamNow { output: [ now ], stream key: [] }

Fragment 61576 (Actor 739469,739470)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.account_group_id] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 61577 (Actor 739471,739472)
StreamProject { exprs: [portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── StreamFilter { predicate: (portfolio_to_account_groups_mv.type = 'all':Varchar) } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, portfolio_to_account_groups_mv.type ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    └── StreamTableScan { table: portfolio_to_account_groups_mv, columns: [portfolio_id, account_group_id, $src, type] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, portfolio_to_account_groups_mv.type ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
        ├── Upstream { output: [ portfolio_id, account_group_id, $src, type ], stream key: [] }
        └── BatchPlanNode { output: [ portfolio_id, account_group_id, $src, type ], stream key: [] }