abor_settlement_positions_mv · explain

← cluster insights objects abor_settlement_positions_mv explain
materialized view · insights.abor_settlement_positions_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredWindow state — add a WHERE rank <= N to bound it
Heat tree Operator graph
37 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
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Expand · (transactions_merged_mv.transaction_settlement_date >= acco…
0% idle 2 actors
Project · (transactions_merged_mv.transaction_settlement_date >= acco…
— — 2 actors
Filter · (transactions_merged_mv.transaction_settlement_date >= acco…
0% idle 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
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
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
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.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 23754 (Actor 106176,106177)
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, source_entity_type, dim_settlement_date, asset_id, $expr2_expanded, currency_code, flag, position_type], pk_columns: [account_group_id, source_entity_type, dim_settlement_date, asset_id, $expr2_expanded, currency_code, flag, position_type], 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, 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, $expr4 ]
└── 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, 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, $expr4 ]
    └── 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, 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, $expr4 ]
        └── 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 23755 (Actor 106179,106178)
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 ]
    └── 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.transactions_intraday_dm.transaction_id_expanded
        │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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: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:Int32_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:Varchar#1_expanded
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
        │   ├── transactions_merged_mv.account_id_expanded
        │   ├── $expr1_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.transactions_intraday_dm.transaction_id
        │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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: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:Int32
        │   ├── 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:Varchar#1
        │   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
        │   ├── transactions_merged_mv.account_id
        │   ├── $expr1
        │   └── flag
        └── stream key:
            ┌── transactions_merged_mv.transactions_intraday_dm.transaction_id
            ├── transactions_merged_mv.transactions_intraday_dm.status_label_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
            ├── transactions_merged_mv.asset_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: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:Int32
            ├── 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_group_id
            ├── 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:Varchar#1
            ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
            ├── transactions_merged_mv.account_id
            ├── $expr1
            └── flag

Fragment 23756 (Actor 106181,106180)
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.transactions_intraday_dm.transaction_id_expanded
│   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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: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:Int32_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:Varchar#1_expanded
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src_expanded
│   ├── transactions_merged_mv.account_id_expanded
│   ├── $expr1_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.transactions_intraday_dm.transaction_id
│   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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: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:Int32
│   ├── 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:Varchar#1
│   ├── account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
│   ├── transactions_merged_mv.account_id
│   ├── $expr1
│   └── flag
├── stream key: [ transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_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: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:Int32, 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_group_id, 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:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id, $expr1, 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.transactions_intraday_dm.transaction_id
  ├─transactions_merged_mv.transactions_intraday_dm.status_label_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: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:Int32
  ├─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:Varchar#1
  ├─account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
  ├─transactions_merged_mv.account_id
  └─$expr1
    ├── 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.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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: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:Int32, 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:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id, $expr1 ]
    ├── stream key: [ transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_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: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:Int32, 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_group_id, 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:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id, $expr1 ]
    └── StreamFilter { predicate: (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.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.transaction_id
        │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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.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: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:Int32
        │   ├── 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: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.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_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: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:Int32, 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_group_id, 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:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id, $expr1 ]
        └── 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.transaction_id
            │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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.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: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:Int32
            │   ├── 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: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.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_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: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:Int32, 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_group_id, 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:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id, $expr1 ]

Fragment 23757 (Actor 106183,106182)
StreamSyncLogStore
├── 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.transaction_id
│   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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.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: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:Int32
│   ├── 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: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.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_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: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:Int32, 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_group_id, 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:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id, $expr1 ]
└── 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 }
    ├── 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.transaction_id
    │   ├── transactions_merged_mv.transactions_intraday_dm.status_label_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.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: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:Int32
    │   ├── 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: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.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_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: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:Int32, 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_group_id, 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:Varchar#1, account_to_account_groups_settlement_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id, $expr1 ]
    ├── 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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_id ] }
    └── 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: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:Int32, 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: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_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: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:Int32, 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_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.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: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 23758 (Actor 106138,106139)
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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_id ] }
└── 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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transactions_intraday_dm.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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, transactions_merged_mv.asset_id ] }
    ├── 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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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 23759 (Actor 106184,106185)
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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_intraday_dm.status_label_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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_merged_mv.transactions_intraday_dm.status_label_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.transaction_id, transactions_intraday_dm.status_label_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.transaction_id, transactions_intraday_dm.status_label_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }

Fragment 23760 (Actor 106137,106136)
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 23761 (Actor 106186,106187)
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: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:Int32, 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: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_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: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:Int32, 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_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.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: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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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: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: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:Int32, 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: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_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: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:Int32, 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_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.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: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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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: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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
