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

← cluster alinma_bff objects book_of_business_transactions_mv explain
Overview Objects Graph History
materialized view · alinma_bff.book_of_business_transactions_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 filtered
145 operators
Materialize · alinma_bff.book_of_business_transactions_mv
0% idle 2 actors
Project · LeftOuter · transactions_dm.transaction_id = income_transactions_dm.tra…
— — 2 actors
TemporalJoin · LeftOuter · transactions_dm.transaction_id = income_transactions_dm.tra…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · income_transactions_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
TemporalJoin · LeftOuter · transactions_dm.transaction_id = fee_transactions_dm.transa…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · fee_transactions_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
TemporalJoin · LeftOuter · transactions_dm.transaction_id = trade_transactions_dm.tran…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · trade_transactions_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
TemporalJoin · LeftOuter · transactions_dm.transaction_type_id = transaction_types_dm.…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transaction_types_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
SyncLogStore · Inner · account_to_account_groups_mv_next.account_id = transactions…
— — 2 actors
HashJoin · Inner · account_to_account_groups_mv_next.account_id = transactions… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transactions_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
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
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · portfolio_to_account_groups_mv.account_group_id = account_t…
— — 2 actors
HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = account_t… 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
Project · account_to_account_groups_mv_next
— — 2 actors
Filter · account_to_account_groups_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_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
StreamScan · portfolio_to_account_groups_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · open_accounts_mv
— — 2 actors
StreamScan · open_accounts_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · open_accounts_mv
— — 2 actors
StreamScan · open_accounts_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · party_to_account_groups_mv_next.account_group_id = account_…
— — 2 actors
HashJoin · Inner · party_to_account_groups_mv_next.account_group_id = account_… 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
Project · account_to_account_groups_mv_next
— — 2 actors
Filter · account_to_account_groups_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_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
StreamScan · party_to_account_groups_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · client_to_account_groups_mv.account_group_id = account_to_a…
— — 2 actors
HashJoin · Inner · client_to_account_groups_mv.account_group_id = account_to_a… 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
Project · account_to_account_groups_mv_next
— — 2 actors
Filter · account_to_account_groups_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_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
StreamScan · client_to_account_groups_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 · alinma_bff.book_of_business_transactions_mv Materialize alinma_bff.book_of_busi… idle · 2 actors Project · LeftOuter · transactions_dm.transaction_id = income_transactions_dm.tra… Project LeftOuter · transaction… — · 2 actors TemporalJoin · LeftOuter · transactions_dm.transaction_id = income_transactions_dm.tra… TemporalJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · income_transactions_dm StreamScan income_transactions_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 TemporalJoin · LeftOuter · transactions_dm.transaction_id = fee_transactions_dm.transa… TemporalJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · fee_transactions_dm StreamScan fee_transactions_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 TemporalJoin · LeftOuter · transactions_dm.transaction_id = trade_transactions_dm.tran… TemporalJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · trade_transactions_dm StreamScan trade_transactions_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 TemporalJoin · LeftOuter · transactions_dm.transaction_type_id = transaction_types_dm.… TemporalJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · transaction_types_dm StreamScan transaction_types_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 SyncLogStore · Inner · account_to_account_groups_mv_next.account_id = transactions… SyncLogStore Inner · account_to_acco… — · 2 actors HashJoin · Inner · account_to_account_groups_mv_next.account_id = transactions… HashJoin Inner · account_to_acco… 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 StreamScan · transactions_dm StreamScan transactions_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 Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · portfolio_to_account_groups_mv.account_group_id = account_t… SyncLogStore Inner · portfolio_to_ac… — · 2 actors HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = account_t… HashJoin Inner · portfolio_to_ac… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · account_to_account_groups_mv_next Project account_to_account_grou… — · 2 actors Filter · account_to_account_groups_mv_next Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_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 StreamScan · portfolio_to_account_groups_mv StreamScan portfolio_to_account_gr… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · open_accounts_mv Project open_accounts_mv — · 2 actors StreamScan · open_accounts_mv StreamScan open_accounts_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · open_accounts_mv Project open_accounts_mv — · 2 actors StreamScan · open_accounts_mv StreamScan open_accounts_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · party_to_account_groups_mv_next.account_group_id = account_… SyncLogStore Inner · party_to_accoun… — · 2 actors HashJoin · Inner · party_to_account_groups_mv_next.account_group_id = account_… HashJoin Inner · party_to_accoun… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · account_to_account_groups_mv_next Project account_to_account_grou… — · 2 actors Filter · account_to_account_groups_mv_next Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_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 StreamScan · party_to_account_groups_mv_next StreamScan party_to_account_groups… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · client_to_account_groups_mv.account_group_id = account_to_a… SyncLogStore Inner · client_to_accou… — · 2 actors HashJoin · Inner · client_to_account_groups_mv.account_group_id = account_to_a… HashJoin Inner · client_to_accou… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · account_to_account_groups_mv_next Project account_to_account_grou… — · 2 actors Filter · account_to_account_groups_mv_next Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_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 StreamScan · client_to_account_groups_mv StreamScan client_to_account_group… 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 61249 (Actor 736254,736255)
StreamMaterialize { columns: [entity_type, entity_id, account_group_type, transaction_id, account_id, asset_id, transaction_type, status_id, side_id, currency_code, quantity, unit_price, gross_value, net_value, external_reference, creation_timestamp, valuation_timestamp, settlement_timestamp, type_id, order_id, description, source_asset_id, source_account_id, fee_type, fee_currency_code, fee_amount, fee_amount_system_currency, order_side_id, custom_fields, account_to_account_groups_mv_next.account_id(hidden)], stream_key: [transaction_id, type_id, account_to_account_groups_mv_next.account_id, entity_type, entity_id, account_group_type], pk_columns: [transaction_id, type_id, account_to_account_groups_mv_next.account_id, entity_type, entity_id, account_group_type], pk_conflict: NoCheck }
├── output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, $expr2, null:Varchar, trade_transactions_dm.order_side_label_id, transactions_dm.currency_code, transactions_dm.quantity, null:Decimal, transactions_dm.gross_value, transactions_dm.net_value, $expr3, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_valuation_timestamp, $expr4, transactions_dm.transaction_type_id, transactions_dm.order_id, transaction_types_dm.name_en, $expr5, $expr6, fee_transactions_dm.fee_type, null:Varchar, null:Decimal, null:Decimal, trade_transactions_dm.order_side_label_id, '[]':Jsonb, account_to_account_groups_mv_next.account_id ]
├── stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ]
└── StreamProject { exprs: ['CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, Coalesce(transaction_types_dm.type, 'OTHER':Varchar) as $expr2, null:Varchar, trade_transactions_dm.order_side_label_id, transactions_dm.currency_code, transactions_dm.quantity, null:Decimal, transactions_dm.gross_value, transactions_dm.net_value, Coalesce(transactions_dm.external_reference, transactions_dm.transaction_id) as $expr3, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_valuation_timestamp, AtTimeZone(transactions_dm.transaction_settlement_date::Timestamp, 'UTC':Varchar) as $expr4, transactions_dm.transaction_type_id, transactions_dm.order_id, transaction_types_dm.name_en, Coalesce(fee_transactions_dm.source_asset_id, income_transactions_dm.source_asset_id) as $expr5, Coalesce(fee_transactions_dm.source_account_id, income_transactions_dm.source_account_id) as $expr6, fee_transactions_dm.fee_type, null:Varchar, null:Decimal, null:Decimal, trade_transactions_dm.order_side_label_id, '[]':Jsonb, account_to_account_groups_mv_next.account_id] }
    ├── output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, $expr2, null:Varchar, trade_transactions_dm.order_side_label_id, transactions_dm.currency_code, transactions_dm.quantity, null:Decimal, transactions_dm.gross_value, transactions_dm.net_value, $expr3, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_valuation_timestamp, $expr4, transactions_dm.transaction_type_id, transactions_dm.order_id, transaction_types_dm.name_en, $expr5, $expr6, fee_transactions_dm.fee_type, null:Varchar, null:Decimal, null:Decimal, trade_transactions_dm.order_side_label_id, '[]':Jsonb, account_to_account_groups_mv_next.account_id ]
    ├── stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ]
    └── StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: transactions_dm.transaction_id = income_transactions_dm.transaction_id, nested_loop: false }
        ├── output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, fee_transactions_dm.fee_type, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id, income_transactions_dm.source_asset_id, income_transactions_dm.source_account_id, account_to_account_groups_mv_next.account_id, income_transactions_dm.transaction_id ]
        ├── stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ]
        ├── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, fee_transactions_dm.fee_type, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id, account_to_account_groups_mv_next.account_id, fee_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
        └── MergeExecutor { output: [ income_transactions_dm.transaction_id, income_transactions_dm.source_asset_id, income_transactions_dm.source_account_id ], stream key: [ income_transactions_dm.transaction_id ] }

Fragment 61250 (Actor 736245,736246)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_id] } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, fee_transactions_dm.fee_type, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id, account_to_account_groups_mv_next.account_id, fee_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
└── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, fee_transactions_dm.fee_type, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id, account_to_account_groups_mv_next.account_id, fee_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }

Fragment 61251 (Actor 736240,736239)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: transactions_dm.transaction_id = fee_transactions_dm.transaction_id, nested_loop: false } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, fee_transactions_dm.fee_type, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id, account_to_account_groups_mv_next.account_id, fee_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
├── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, account_to_account_groups_mv_next.account_id, trade_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
└── MergeExecutor { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.fee_type, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id ], stream key: [ fee_transactions_dm.transaction_id ] }

Fragment 61252 (Actor 738320,738321)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_id] } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, account_to_account_groups_mv_next.account_id, trade_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
└── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, account_to_account_groups_mv_next.account_id, trade_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }

Fragment 61253 (Actor 738325,738324)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: transactions_dm.transaction_id = trade_transactions_dm.transaction_id, nested_loop: false } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, trade_transactions_dm.order_side_label_id, account_to_account_groups_mv_next.account_id, trade_transactions_dm.transaction_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
├── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, account_to_account_groups_mv_next.account_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
└── MergeExecutor { output: [ trade_transactions_dm.transaction_id, trade_transactions_dm.order_side_label_id ], stream key: [ trade_transactions_dm.transaction_id ] }

Fragment 61254 (Actor 738708,738709)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_id] } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, account_to_account_groups_mv_next.account_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
└── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, account_to_account_groups_mv_next.account_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id ] }

Fragment 61255 (Actor 736218,736219)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: transactions_dm.transaction_type_id = transaction_types_dm.transaction_type_id, nested_loop: false } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, transaction_types_dm.type, transaction_types_dm.name_en, account_to_account_groups_mv_next.account_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id ] }
├── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, account_to_account_groups_mv_next.account_id ], stream key: [ transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en ], stream key: [ transaction_types_dm.transaction_type_id ] }

Fragment 61256 (Actor 738711,738710)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_type_id] } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, account_to_account_groups_mv_next.account_id ], stream key: [ transactions_dm.transaction_type_id, account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, account_to_account_groups_mv_next.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id ] }

Fragment 61257 (Actor 738712,738713)
StreamSyncLogStore { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, account_to_account_groups_mv_next.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id ] }
└── StreamHashJoin { type: Inner, predicate: account_to_account_groups_mv_next.account_id = transactions_dm.account_id } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference, account_to_account_groups_mv_next.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, transactions_dm.transaction_id ] }
    ├── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
    └── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference ], stream key: [ transactions_dm.account_id, transactions_dm.transaction_id ] }

Fragment 61258 (Actor 738714,738715)
StreamLocalityProvider { locality_columns: [account_to_account_groups_mv_next.account_id] } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ] }
└── MergeExecutor { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id ], stream key: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id ] }

Fragment 61259 (Actor 738716,738717)
StreamProject { exprs: ['CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id] } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id ], stream key: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id ] }
└── StreamHashAgg { group_key: ['CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id], aggs: [count] } { output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, count ], stream key: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id ] }
    └── StreamLocalityProvider { locality_columns: ['CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id] }
        ├── output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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, null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, $src ]
        ├── stream key:
        │   ┌── 'CLIENT':Varchar
        │   ├── client_to_account_groups_mv.client_id
        │   ├── client_to_account_groups_mv.type
        │   ├── account_to_account_groups_mv_next.account_id
        │   ├── client_to_account_groups_mv.account_group_id
        │   ├── client_to_account_groups_mv.client_id
        │   ├── client_to_account_groups_mv.$src
        │   ├── account_to_account_groups_mv_next.account_id
        │   ├── 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
        │   ├── null:Varchar
        │   └── $src
        └── MergeExecutor
            ├── output:
            │   ┌── 'CLIENT':Varchar
            │   ├── client_to_account_groups_mv.client_id
            │   ├── client_to_account_groups_mv.type
            │   ├── account_to_account_groups_mv_next.account_id
            │   ├── client_to_account_groups_mv.$src
            │   ├── account_to_account_groups_mv_next.null:Int32
            │   ├── account_to_account_groups_mv_next.$src
            │   ├── account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
            │   ├── account_to_account_groups_mv_next.account_groups_mv_next.$src
            │   ├── client_to_account_groups_mv.account_group_id
            │   ├── client_to_account_groups_mv.client_id
            │   ├── account_to_account_groups_mv_next.account_id
            │   ├── 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:Varchar#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.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
            │   ├── null:Varchar
            │   ├── account_to_account_groups_mv_next.null:Date
            │   ├── account_to_account_groups_mv_next.null:Date#1
            │   └── $src
            └── stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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, null:Varchar, $src ]

Fragment 61260 (Actor 738719,738718)
StreamUnion { all: true }
├── output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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, null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, $src ]
├── stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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, null:Varchar, $src ]
├── MergeExecutor
│   ├── output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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, null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, 0:Int32 ]
│   └── stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]
├── MergeExecutor
│   ├── output:
│   │   ┌── 'PARTY':Varchar
│   │   ├── party_to_account_groups_mv_next.party_id
│   │   ├── party_to_account_groups_mv_next.type
│   │   ├── account_to_account_groups_mv_next.account_id
│   │   ├── party_to_account_groups_mv_next.$src
│   │   ├── account_to_account_groups_mv_next.null:Int32
│   │   ├── account_to_account_groups_mv_next.$src
│   │   ├── account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
│   │   ├── account_to_account_groups_mv_next.account_groups_mv_next.$src
│   │   ├── party_to_account_groups_mv_next.account_group_id
│   │   ├── party_to_account_groups_mv_next.parties.id
│   │   ├── party_to_account_groups_mv_next.null:Varchar
│   │   ├── account_to_account_groups_mv_next.account_id
│   │   ├── 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:Varchar#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.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.null:Date
│   │   ├── account_to_account_groups_mv_next.null:Date#1
│   │   └── 1:Int32
│   └── stream key: [ party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, 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 ]
├── MergeExecutor { output: [ 'ACCOUNT':Varchar, open_accounts_mv.account_id, 'all':Varchar, open_accounts_mv.account_id, null:Int32, null:Int32, null:Int32, null:Int32, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 2:Int32 ], stream key: [ open_accounts_mv.account_id ] }
├── MergeExecutor { output: [ 'ACCOUNT':Varchar, open_accounts_mv.account_id, $expr1, open_accounts_mv.account_id, null:Int32, null:Int32, null:Int32, null:Int32, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 3:Int32 ], stream key: [ open_accounts_mv.account_id ] }
└── MergeExecutor
    ├── output:
    │   ┌── 'PORTFOLIO':Varchar
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── portfolio_to_account_groups_mv.type
    │   ├── account_to_account_groups_mv_next.account_id
    │   ├── portfolio_to_account_groups_mv.$src
    │   ├── account_to_account_groups_mv_next.null:Int32
    │   ├── account_to_account_groups_mv_next.$src
    │   ├── account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
    │   ├── account_to_account_groups_mv_next.account_groups_mv_next.$src
    │   ├── portfolio_to_account_groups_mv.account_group_id
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── account_to_account_groups_mv_next.account_id
    │   ├── 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:Varchar#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.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
    │   ├── null:Varchar
    │   ├── account_to_account_groups_mv_next.null:Date
    │   ├── account_to_account_groups_mv_next.null:Date#1
    │   └── 4:Int32
    └── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]

Fragment 61261 (Actor 738722,738723)
StreamProject { exprs: ['CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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, null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, 0:Int32] }
├── output: [ 'CLIENT':Varchar, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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, null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, 0:Int32 ]
├── stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]
└── MergeExecutor
    ├── output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_group_id, 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: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]

Fragment 61262 (Actor 738720,738721)
StreamSyncLogStore
├── output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_group_id, 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: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]
└── StreamHashJoin { type: Inner, predicate: client_to_account_groups_mv.account_group_id = account_to_account_groups_mv_next.account_group_id }
    ├── output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_group_id, 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: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]
    ├── MergeExecutor { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
    └── MergeExecutor
        ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]

Fragment 61263 (Actor 738724,738725)
StreamLocalityProvider { locality_columns: [client_to_account_groups_mv.account_group_id] } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }

Fragment 61264 (Actor 738727,738726)
StreamTableScan { table: client_to_account_groups_mv, columns: [client_id, account_group_id, type, $src] } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
├── Upstream { output: [ client_id, account_group_id, type, $src ], stream key: [] }
└── BatchPlanNode { output: [ client_id, account_group_id, type, $src ], stream key: [] }

Fragment 61265 (Actor 738729,738728)
StreamProject { exprs: [account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
└── StreamFilter { predicate: IsNull(account_to_account_groups_mv_next.effective_end_date) }
    ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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, account_to_account_groups_mv_next.effective_end_date ]
    ├── stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
    └── StreamTableScan { table: account_to_account_groups_mv_next, columns: [account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date] }
        ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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, account_to_account_groups_mv_next.effective_end_date ]
        ├── stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
        ├── Upstream { output: [ account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date ], stream key: [] }

Fragment 61266 (Actor 738731,738730)
StreamProject { exprs: ['PARTY':Varchar, party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, account_to_account_groups_mv_next.account_id, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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.null:Date, account_to_account_groups_mv_next.null:Date#1, 1:Int32] }
├── output: [ 'PARTY':Varchar, party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, account_to_account_groups_mv_next.account_id, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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.null:Date, account_to_account_groups_mv_next.null:Date#1, 1:Int32 ]
├── stream key: [ party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, 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 ]
└── MergeExecutor
    ├── output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, account_to_account_groups_mv_next.account_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_group_id, 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: [ party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, 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 ]

Fragment 61267 (Actor 738732,738733)
StreamSyncLogStore
├── output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, account_to_account_groups_mv_next.account_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_group_id, 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: [ party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, 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 ]
└── StreamHashJoin { type: Inner, predicate: party_to_account_groups_mv_next.account_group_id = account_to_account_groups_mv_next.account_group_id }
    ├── output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, account_to_account_groups_mv_next.account_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_group_id, 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: [ party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, 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 ]
    ├── MergeExecutor { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.type, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
    └── MergeExecutor
        ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]

Fragment 61268 (Actor 738734,738735)
StreamLocalityProvider { locality_columns: [party_to_account_groups_mv_next.account_group_id] } { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.type, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.type, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }

Fragment 61269 (Actor 738736,738737)
StreamTableScan { table: party_to_account_groups_mv_next, columns: [party_id, account_group_id, type, parties.id, null:Varchar, $src] } { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.type, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
├── Upstream { output: [ party_id, account_group_id, type, parties.id, null:Varchar, $src ], stream key: [] }
└── BatchPlanNode { output: [ party_id, account_group_id, type, parties.id, null:Varchar, $src ], stream key: [] }

Fragment 61270 (Actor 738739,738738)
StreamProject { exprs: [account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
└── StreamFilter { predicate: IsNull(account_to_account_groups_mv_next.effective_end_date) }
    ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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, account_to_account_groups_mv_next.effective_end_date ]
    ├── stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
    └── StreamTableScan { table: account_to_account_groups_mv_next, columns: [account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date] }
        ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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, account_to_account_groups_mv_next.effective_end_date ]
        ├── stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
        ├── Upstream { output: [ account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date ], stream key: [] }

Fragment 61271 (Actor 738740,738741)
StreamProject { exprs: ['ACCOUNT':Varchar, open_accounts_mv.account_id, 'all':Varchar, open_accounts_mv.account_id, null:Int32, null:Int32, null:Int32, null:Int32, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 2:Int32] } { output: [ 'ACCOUNT':Varchar, open_accounts_mv.account_id, 'all':Varchar, open_accounts_mv.account_id, null:Int32, null:Int32, null:Int32, null:Int32, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 2:Int32 ], stream key: [ open_accounts_mv.account_id ] }
└── StreamTableScan { table: open_accounts_mv, columns: [account_id] } { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
    ├── Upstream { output: [ account_id ], stream key: [] }
    └── BatchPlanNode { output: [ account_id ], stream key: [] }

Fragment 61272 (Actor 738743,738742)
StreamProject { exprs: ['ACCOUNT':Varchar, open_accounts_mv.account_id, Case(open_accounts_mv.is_restricted, 'restricted':Varchar, 'un_restricted':Varchar) as $expr1, open_accounts_mv.account_id, null:Int32, null:Int32, null:Int32, null:Int32, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 3:Int32] } { output: [ 'ACCOUNT':Varchar, open_accounts_mv.account_id, $expr1, open_accounts_mv.account_id, null:Int32, null:Int32, null:Int32, null:Int32, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 3:Int32 ], stream key: [ open_accounts_mv.account_id ] }
└── StreamTableScan { table: open_accounts_mv, columns: [account_id, is_restricted] } { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }
    ├── Upstream { output: [ account_id, is_restricted ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, is_restricted ], stream key: [] }

Fragment 61273 (Actor 738746,738747)
StreamProject { exprs: ['PORTFOLIO':Varchar, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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, null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, 4:Int32] }
├── output: [ 'PORTFOLIO':Varchar, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, account_to_account_groups_mv_next.account_id, 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:Varchar#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.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, null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, 4:Int32 ]
├── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]
└── MergeExecutor
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_group_id, 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: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]

Fragment 61274 (Actor 738745,738744)
StreamSyncLogStore
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_group_id, 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: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]
└── StreamHashJoin { type: Inner, predicate: portfolio_to_account_groups_mv.account_group_id = account_to_account_groups_mv_next.account_group_id }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, account_to_account_groups_mv_next.account_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_group_id, 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: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, account_to_account_groups_mv_next.account_id, 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 ]
    ├── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    └── MergeExecutor
        ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]

Fragment 61275 (Actor 738748,738749)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.account_group_id] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 61276 (Actor 738751,738750)
StreamTableScan { table: portfolio_to_account_groups_mv, columns: [portfolio_id, account_group_id, type, $src] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
├── Upstream { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }

Fragment 61277 (Actor 738753,738752)
StreamProject { exprs: [account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
└── StreamFilter { predicate: IsNull(account_to_account_groups_mv_next.effective_end_date) }
    ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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, account_to_account_groups_mv_next.effective_end_date ]
    ├── stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
    └── StreamTableScan { table: account_to_account_groups_mv_next, columns: [account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date] }
        ├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, 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, account_to_account_groups_mv_next.effective_end_date ]
        ├── stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, 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 ]
        ├── Upstream { output: [ account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, account_group_id, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date ], stream key: [] }

Fragment 61278 (Actor 738754,738755)
StreamLocalityProvider { locality_columns: [transactions_dm.account_id] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference ], stream key: [ transactions_dm.account_id, transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference ], stream key: [ transactions_dm.transaction_id ] }

Fragment 61279 (Actor 738757,738756)
StreamTableScan { table: transactions_dm, columns: [transaction_id, account_id, asset_id, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, gross_value, net_value, quantity, order_id, external_reference] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_timestamp, transactions_dm.transaction_settlement_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.gross_value, transactions_dm.net_value, transactions_dm.quantity, transactions_dm.order_id, transactions_dm.external_reference ], stream key: [ transactions_dm.transaction_id ] }
├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, gross_value, net_value, quantity, order_id, external_reference ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, gross_value, net_value, quantity, order_id, external_reference ], stream key: [] }

Fragment 61280 (Actor 736222,736223)
StreamTableScan { table: transaction_types_dm, columns: [transaction_type_id, type, name_en] } { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en ], stream key: [ transaction_types_dm.transaction_type_id ] }
├── Upstream { output: [ transaction_type_id, type, name_en ], stream key: [] }
└── BatchPlanNode { output: [ transaction_type_id, type, name_en ], stream key: [] }

Fragment 61281 (Actor 738319,738318)
StreamTableScan { table: trade_transactions_dm, columns: [transaction_id, order_side_label_id] } { output: [ trade_transactions_dm.transaction_id, trade_transactions_dm.order_side_label_id ], stream key: [ trade_transactions_dm.transaction_id ] }
├── Upstream { output: [ transaction_id, order_side_label_id ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, order_side_label_id ], stream key: [] }

Fragment 61282 (Actor 736243,736244)
StreamTableScan { table: fee_transactions_dm, columns: [transaction_id, fee_type, source_asset_id, source_account_id] } { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.fee_type, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id ], stream key: [ fee_transactions_dm.transaction_id ] }
├── Upstream { output: [ transaction_id, fee_type, source_asset_id, source_account_id ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, fee_type, source_asset_id, source_account_id ], stream key: [] }

Fragment 61283 (Actor 736250,736251)
StreamTableScan { table: income_transactions_dm, columns: [transaction_id, source_asset_id, source_account_id] } { output: [ income_transactions_dm.transaction_id, income_transactions_dm.source_asset_id, income_transactions_dm.source_account_id ], stream key: [ income_transactions_dm.transaction_id ] }
├── Upstream { output: [ transaction_id, source_asset_id, source_account_id ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, source_asset_id, source_account_id ], stream key: [] }