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

← cluster insights objects abor_settlement_positions_mv explain
Overview Objects Graph History
materialized view · insights.abor_settlement_positions_mv profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredWindow state — add a WHERE rank <= N to bound it
47 operators
Materialize · insights.abor_settlement_positions_mv
0% idle 2 actors
Project
— — 2 actors
OverWindow Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Expand
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_merged_mv.account_id = account_to_account_grou…
— — 2 actors
HashJoin · Inner · transactions_merged_mv.account_id = account_to_account_grou… 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
Filter · account_to_account_groups_settlement_binned_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_settlement_binned_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · LeftOuter · transactions_merged_mv.asset_id = assets_dm.id, nested_loop…
— — 2 actors
TemporalJoin · LeftOuter · transactions_merged_mv.asset_id = assets_dm.id, nested_loop…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · transactions_merged_mv
0% idle 2 actors
StreamScan · transactions_merged_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · insights.abor_settlement_positions_mv Materialize insights.abor_settlemen… idle · 2 actors Project Project — · 2 actors OverWindow OverWindow idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Expand Expand idle · 2 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · transactions_merged_mv.account_id = account_to_account_grou… SyncLogStore Inner · transactions_me… — · 2 actors HashJoin · Inner · transactions_merged_mv.account_id = account_to_account_grou… HashJoin Inner · transactions_me… 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 Filter · account_to_account_groups_settlement_binned_mv_next Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_settlement_binned_mv_next StreamScan account_to_account_grou… 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 · LeftOuter · transactions_merged_mv.asset_id = assets_dm.id, nested_loop… Project LeftOuter · transaction… — · 2 actors TemporalJoin · LeftOuter · transactions_merged_mv.asset_id = assets_dm.id, nested_loop… TemporalJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm StreamScan assets_dm 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 Filter · transactions_merged_mv Filter transactions_merged_mv idle · 2 actors StreamScan · transactions_merged_mv StreamScan transactions_merged_mv 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 61284 (Actor 738575,738574)
StreamMaterialize { columns: [account_group_id, source_entity_type, dim_settlement_date, asset_id, position_type, currency_code, settlement_quantity_delta, settlement_value_delta, settled_quantity, settled_value, transaction_count, $expr2_expanded(hidden), flag(hidden)], stream_key: [account_group_id, asset_id, position_type, currency_code, source_entity_type, dim_settlement_date, $expr2_expanded, flag], pk_columns: [account_group_id, asset_id, position_type, currency_code, source_entity_type, dim_settlement_date, $expr2_expanded, flag], pk_conflict: NoCheck }
├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), sum, sum, count(transactions_merged_mv.transaction_id), $expr2_expanded, flag ]
├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, $expr2_expanded, flag ]
└── StreamProject { exprs: [account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), sum, sum, count(transactions_merged_mv.transaction_id), $expr2_expanded, flag] }
    ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), sum, sum, count(transactions_merged_mv.transaction_id), $expr2_expanded, flag ]
    ├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, $expr2_expanded, flag ]
    └── StreamOverWindow { window_functions: [sum(sum($expr3)) OVER(PARTITION BY account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded ORDER BY transactions_merged_mv.transaction_settlement_date_expanded ASC ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW), sum(sum(transactions_merged_mv.net_value)) OVER(PARTITION BY account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded ORDER BY transactions_merged_mv.transaction_settlement_date_expanded ASC ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)] }
        ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), $expr2_expanded, flag, sum, sum ]
        ├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, $expr2_expanded, flag ]
        └── StreamLocalityProvider { locality_columns: [account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded] }
            ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), $expr2_expanded, flag ]
            ├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, $expr2_expanded, flag ]
            └── MergeExecutor
                ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), $expr2_expanded, flag ]
                └── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr2_expanded, transactions_merged_mv.currency_code_expanded, flag ]

Fragment 61285 (Actor 738576,738577)
StreamProject { exprs: [account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, Case((Case((0:Int64 = flag), 0:Int32, (1:Int64 = flag), 1:Int32) = 1:Int32), 'POSITION':Varchar, $expr2_expanded) as $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), $expr2_expanded, flag] }
├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr4, transactions_merged_mv.currency_code_expanded, sum($expr3), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), $expr2_expanded, flag ]
├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr2_expanded, transactions_merged_mv.currency_code_expanded, flag ]
└── StreamHashAgg { group_key: [account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr2_expanded, transactions_merged_mv.currency_code_expanded, flag], aggs: [sum($expr3), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), count] }
    ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr2_expanded, transactions_merged_mv.currency_code_expanded, flag, sum($expr3), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), count ]
    ├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr2_expanded, transactions_merged_mv.currency_code_expanded, flag ]
    └── StreamLocalityProvider { locality_columns: [account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded, account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded, transactions_merged_mv.transaction_settlement_date_expanded, transactions_merged_mv.asset_id_expanded, $expr2_expanded, transactions_merged_mv.currency_code_expanded, flag] }
        ├── output:
        │   ┌── account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded
        │   ├── transactions_merged_mv.transaction_settlement_date_expanded
        │   ├── transactions_merged_mv.asset_id_expanded
        │   ├── $expr2_expanded
        │   ├── transactions_merged_mv.currency_code_expanded
        │   ├── $expr3_expanded
        │   ├── transactions_merged_mv.net_value_expanded
        │   ├── transactions_merged_mv.transaction_id_expanded
        │   ├── transactions_merged_mv.account_id_expanded
        │   ├── $expr1_expanded
        │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_id_expanded
        │   ├── transactions_merged_mv.transactions_intraday_dm.transaction_id_expanded
        │   ├── transactions_merged_mv.null:Varchar_expanded
        │   ├── transactions_merged_mv.null:Varchar#1_expanded
        │   ├── transactions_merged_mv.null:Varchar#2_expanded
        │   ├── transactions_merged_mv.null:Varchar#3_expanded
        │   ├── transactions_merged_mv.$src_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_group_id
        │   ├── account_to_account_groups_settlement_binned_mv_next.source_entity_type
        │   ├── transactions_merged_mv.transaction_settlement_date
        │   ├── transactions_merged_mv.asset_id
        │   ├── $expr2
        │   ├── transactions_merged_mv.currency_code
        │   ├── $expr3
        │   ├── transactions_merged_mv.net_value
        │   ├── transactions_merged_mv.transaction_id
        │   ├── transactions_merged_mv.account_id
        │   ├── $expr1
        │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_id
        │   ├── transactions_merged_mv.transactions_intraday_dm.transaction_id
        │   ├── transactions_merged_mv.null:Varchar
        │   ├── transactions_merged_mv.null:Varchar#1
        │   ├── transactions_merged_mv.null:Varchar#2
        │   ├── transactions_merged_mv.null:Varchar#3
        │   ├── transactions_merged_mv.$src
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
        │   └── flag
        ├── stream key:
        │   ┌── account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded
        │   ├── transactions_merged_mv.transaction_settlement_date_expanded
        │   ├── transactions_merged_mv.asset_id_expanded
        │   ├── $expr2_expanded
        │   ├── transactions_merged_mv.currency_code_expanded
        │   ├── flag
        │   ├── transactions_merged_mv.account_id
        │   ├── $expr1
        │   ├── transactions_merged_mv.asset_id
        │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_id
        │   ├── transactions_merged_mv.transactions_intraday_dm.transaction_id
        │   ├── transactions_merged_mv.null:Varchar
        │   ├── transactions_merged_mv.null:Varchar#1
        │   ├── transactions_merged_mv.null:Varchar#2
        │   ├── transactions_merged_mv.null:Varchar#3
        │   ├── transactions_merged_mv.$src
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_group_id
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
        │   └── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
        └── MergeExecutor
            ├── output:
            │   ┌── account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded
            │   ├── transactions_merged_mv.transaction_settlement_date_expanded
            │   ├── transactions_merged_mv.asset_id_expanded
            │   ├── $expr2_expanded
            │   ├── transactions_merged_mv.currency_code_expanded
            │   ├── $expr3_expanded
            │   ├── transactions_merged_mv.net_value_expanded
            │   ├── transactions_merged_mv.transaction_id_expanded
            │   ├── transactions_merged_mv.account_id_expanded
            │   ├── $expr1_expanded
            │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_id_expanded
            │   ├── transactions_merged_mv.transactions_intraday_dm.transaction_id_expanded
            │   ├── transactions_merged_mv.null:Varchar_expanded
            │   ├── transactions_merged_mv.null:Varchar#1_expanded
            │   ├── transactions_merged_mv.null:Varchar#2_expanded
            │   ├── transactions_merged_mv.null:Varchar#3_expanded
            │   ├── transactions_merged_mv.$src_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_group_id
            │   ├── account_to_account_groups_settlement_binned_mv_next.source_entity_type
            │   ├── transactions_merged_mv.transaction_settlement_date
            │   ├── transactions_merged_mv.asset_id
            │   ├── $expr2
            │   ├── transactions_merged_mv.currency_code
            │   ├── $expr3
            │   ├── transactions_merged_mv.net_value
            │   ├── transactions_merged_mv.transaction_id
            │   ├── transactions_merged_mv.account_id
            │   ├── $expr1
            │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_id
            │   ├── transactions_merged_mv.transactions_intraday_dm.transaction_id
            │   ├── transactions_merged_mv.null:Varchar
            │   ├── transactions_merged_mv.null:Varchar#1
            │   ├── transactions_merged_mv.null:Varchar#2
            │   ├── transactions_merged_mv.null:Varchar#3
            │   ├── transactions_merged_mv.$src
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
            │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
            │   └── flag
            └── stream key:
                ┌── transactions_merged_mv.account_id
                ├── $expr1
                ├── transactions_merged_mv.asset_id
                ├── transactions_merged_mv.transactions_intraday_dm.status_label_id
                ├── transactions_merged_mv.transactions_intraday_dm.transaction_id
                ├── transactions_merged_mv.null:Varchar
                ├── transactions_merged_mv.null:Varchar#1
                ├── transactions_merged_mv.null:Varchar#2
                ├── transactions_merged_mv.null:Varchar#3
                ├── transactions_merged_mv.$src
                ├── account_to_account_groups_settlement_binned_mv_next.account_group_id
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
                ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
                └── flag

Fragment 61286 (Actor 738578,738579)
StreamExpand { column_subsets: [[account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.source_entity_type, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.asset_id, $expr2, transactions_merged_mv.currency_code], [account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.source_entity_type, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code]] }
├── output:
│   ┌── account_to_account_groups_settlement_binned_mv_next.account_group_id_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.source_entity_type_expanded
│   ├── transactions_merged_mv.transaction_settlement_date_expanded
│   ├── transactions_merged_mv.asset_id_expanded
│   ├── $expr2_expanded
│   ├── transactions_merged_mv.currency_code_expanded
│   ├── $expr3_expanded
│   ├── transactions_merged_mv.net_value_expanded
│   ├── transactions_merged_mv.transaction_id_expanded
│   ├── transactions_merged_mv.account_id_expanded
│   ├── $expr1_expanded
│   ├── transactions_merged_mv.transactions_intraday_dm.status_label_id_expanded
│   ├── transactions_merged_mv.transactions_intraday_dm.transaction_id_expanded
│   ├── transactions_merged_mv.null:Varchar_expanded
│   ├── transactions_merged_mv.null:Varchar#1_expanded
│   ├── transactions_merged_mv.null:Varchar#2_expanded
│   ├── transactions_merged_mv.null:Varchar#3_expanded
│   ├── transactions_merged_mv.$src_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_group_id
│   ├── account_to_account_groups_settlement_binned_mv_next.source_entity_type
│   ├── transactions_merged_mv.transaction_settlement_date
│   ├── transactions_merged_mv.asset_id
│   ├── $expr2
│   ├── transactions_merged_mv.currency_code
│   ├── $expr3
│   ├── transactions_merged_mv.net_value
│   ├── transactions_merged_mv.transaction_id
│   ├── transactions_merged_mv.account_id
│   ├── $expr1
│   ├── transactions_merged_mv.transactions_intraday_dm.status_label_id
│   ├── transactions_merged_mv.transactions_intraday_dm.transaction_id
│   ├── transactions_merged_mv.null:Varchar
│   ├── transactions_merged_mv.null:Varchar#1
│   ├── transactions_merged_mv.null:Varchar#2
│   ├── transactions_merged_mv.null:Varchar#3
│   ├── transactions_merged_mv.$src
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
│   └── flag
├── stream key: [ transactions_merged_mv.account_id, $expr1, transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flag ]
└── StreamProject
└─exprs:
  ┌─account_to_account_groups_settlement_binned_mv_next.account_group_id
  ├─account_to_account_groups_settlement_binned_mv_next.source_entity_type
  ├─transactions_merged_mv.transaction_settlement_date
  ├─transactions_merged_mv.asset_id
  ├─Case((assets_dm.type = 'LIABILITY':Varchar), 'LIABILITY':Varchar, 'ASSET':Varchar) as $expr2
  ├─transactions_merged_mv.currency_code
  ├─Case((assets_dm.type = 'CASH':Varchar), transactions_merged_mv.net_value, Coalesce(transactions_merged_mv.quantity, 0:Decimal)) as $expr3
  ├─transactions_merged_mv.net_value
  ├─transactions_merged_mv.transaction_id
  ├─transactions_merged_mv.account_id
  ├─$expr1
  ├─transactions_merged_mv.transactions_intraday_dm.status_label_id
  ├─transactions_merged_mv.transactions_intraday_dm.transaction_id
  ├─transactions_merged_mv.null:Varchar
  ├─transactions_merged_mv.null:Varchar#1
  ├─transactions_merged_mv.null:Varchar#2
  ├─transactions_merged_mv.null:Varchar#3
  ├─transactions_merged_mv.$src
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  └─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
    ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.source_entity_type, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.asset_id, $expr2, transactions_merged_mv.currency_code, $expr3, transactions_merged_mv.net_value, transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    ├── stream key: [ transactions_merged_mv.account_id, $expr1, transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    └── MergeExecutor
        ├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.source_entity_type, transactions_merged_mv.account_id, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
        └── stream key: [ transactions_merged_mv.account_id, $expr1, transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]

Fragment 61287 (Actor 738580,738581)
StreamSyncLogStore
├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.source_entity_type, transactions_merged_mv.account_id, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
├── stream key: [ transactions_merged_mv.account_id, $expr1, transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
└── StreamHashJoin { type: Inner, predicate: transactions_merged_mv.account_id = account_to_account_groups_settlement_binned_mv_next.account_id AND $expr1 = account_to_account_groups_settlement_binned_mv_next.dim_settlement_month AND (transactions_merged_mv.transaction_settlement_date >= account_to_account_groups_settlement_binned_mv_next.effective_start_date) AND (IsNull(account_to_account_groups_settlement_binned_mv_next.effective_end_date) OR (transactions_merged_mv.transaction_settlement_date < account_to_account_groups_settlement_binned_mv_next.effective_end_date)) AND (IsNull(account_to_account_groups_settlement_binned_mv_next.opening_date) OR (transactions_merged_mv.transaction_settlement_date >= account_to_account_groups_settlement_binned_mv_next.opening_date)) }
    ├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.source_entity_type, transactions_merged_mv.account_id, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    ├── stream key: [ transactions_merged_mv.account_id, $expr1, transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    ├── MergeExecutor { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.account_id, $expr1, transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
    └── MergeExecutor
        ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.effective_start_date, account_to_account_groups_settlement_binned_mv_next.effective_end_date, account_to_account_groups_settlement_binned_mv_next.opening_date, account_to_account_groups_settlement_binned_mv_next.source_entity_type, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
        └── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]

Fragment 61288 (Actor 738582,738583)
StreamLocalityProvider { locality_columns: [transactions_merged_mv.account_id, $expr1] } { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.account_id, $expr1, transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
└── MergeExecutor { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }

Fragment 61289 (Actor 741110,741109)
StreamProject { exprs: [transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, AtTimeZone(DateTrunc('MONTH':Varchar, AtTimeZone(transactions_merged_mv.transaction_settlement_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src] } { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, $expr1, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
└── StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: transactions_merged_mv.asset_id = assets_dm.id, nested_loop: false } { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, assets_dm.id ], stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
    ├── MergeExecutor { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.type ], stream key: [ assets_dm.id ] }

Fragment 61290 (Actor 738759,738758)
StreamLocalityProvider { locality_columns: [transactions_merged_mv.asset_id] } { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
└── MergeExecutor { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }

Fragment 61291 (Actor 738761,738760)
StreamFilter { predicate: Not(IsNull(transactions_merged_mv.transaction_settlement_date)) } { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
└── StreamTableScan { table: transactions_merged_mv, columns: [transaction_id, account_id, asset_id, transaction_settlement_date, currency_code, net_value, quantity, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src] } { output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
    ├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_settlement_date, currency_code, net_value, quantity, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }
    └── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_settlement_date, currency_code, net_value, quantity, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }

Fragment 61292 (Actor 741115,741116)
StreamTableScan { table: assets_dm, columns: [id, type] } { output: [ assets_dm.id, assets_dm.type ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, type ], stream key: [] }
└── BatchPlanNode { output: [ id, type ], stream key: [] }

Fragment 61293 (Actor 738763,738762)
StreamLocalityProvider { locality_columns: [account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month] }
├── output: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.effective_start_date, account_to_account_groups_settlement_binned_mv_next.effective_end_date, account_to_account_groups_settlement_binned_mv_next.opening_date, account_to_account_groups_settlement_binned_mv_next.source_entity_type, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
└── MergeExecutor
    ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.effective_start_date, account_to_account_groups_settlement_binned_mv_next.effective_end_date, account_to_account_groups_settlement_binned_mv_next.opening_date, account_to_account_groups_settlement_binned_mv_next.source_entity_type, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    └── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month ]

Fragment 61294 (Actor 738765,738764)
StreamFilter { predicate: (account_to_account_groups_settlement_binned_mv_next.source_entity_type = 'account':Varchar) }
├── output: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.effective_start_date, account_to_account_groups_settlement_binned_mv_next.effective_end_date, account_to_account_groups_settlement_binned_mv_next.opening_date, account_to_account_groups_settlement_binned_mv_next.source_entity_type, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month ]
└── StreamTableScan { table: account_to_account_groups_settlement_binned_mv_next, columns: [account_id, account_group_id, effective_start_date, effective_end_date, opening_date, source_entity_type, dim_settlement_month, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src] }
    ├── output: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.effective_start_date, account_to_account_groups_settlement_binned_mv_next.effective_end_date, account_to_account_groups_settlement_binned_mv_next.opening_date, account_to_account_groups_settlement_binned_mv_next.source_entity_type, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    ├── stream key: [ account_to_account_groups_settlement_binned_mv_next.account_id, account_to_account_groups_settlement_binned_mv_next.account_group_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_settlement_binned_mv_next.dim_settlement_month ]
    ├── Upstream { output: [ account_id, account_group_id, effective_start_date, effective_end_date, opening_date, source_entity_type, dim_settlement_month, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, account_group_id, effective_start_date, effective_end_date, opening_date, source_entity_type, dim_settlement_month, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [] }