RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster alpheya_experience_bff objects party_fee_totals_mv explain
Overview Objects Graph History
materialized view · alpheya_experience_bff.party_fee_totals_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
53 operators
Materialize · alpheya_experience_bff.party_fee_totals_mv
0% idle 2 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
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · flow_values_mv_next.account_group_id = party_to_account_gro…
— — 2 actors
HashJoin · Inner · flow_values_mv_next.account_group_id = party_to_account_gro… 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
SyncLogStore · Inner · party_active_customer_parties_mv.party_id = party_to_accoun…
— — 2 actors
HashJoin · Inner · party_active_customer_parties_mv.party_id = party_to_accoun… 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 · party_to_account_groups_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · party_active_customer_parties_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · fee_transactions_dm.transaction_id = flow_values_mv_next.tr…
— — 2 actors
HashJoin · Inner · fee_transactions_dm.transaction_id = flow_values_mv_next.tr… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · flow_values_mv_next
— — 2 actors
Filter · flow_values_mv_next
0% idle 2 actors
StreamScan · flow_values_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · fee_transactions_dm
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 · alpheya_experience_bff.party_fee_totals_mv Materialize alpheya_experience_bff.… idle · 2 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider 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 · flow_values_mv_next.account_group_id = party_to_account_gro… SyncLogStore Inner · flow_values_mv_… — · 2 actors HashJoin · Inner · flow_values_mv_next.account_group_id = party_to_account_gro… HashJoin Inner · flow_values_mv_… 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 SyncLogStore · Inner · party_active_customer_parties_mv.party_id = party_to_accoun… SyncLogStore Inner · party_active_cu… — · 2 actors HashJoin · Inner · party_active_customer_parties_mv.party_id = party_to_accoun… HashJoin Inner · party_active_cu… 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 · 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 StreamScan · party_active_customer_parties_mv StreamScan party_active_customer_p… 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 · fee_transactions_dm.transaction_id = flow_values_mv_next.tr… SyncLogStore Inner · fee_transaction… — · 2 actors HashJoin · Inner · fee_transactions_dm.transaction_id = flow_values_mv_next.tr… HashJoin Inner · fee_transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · flow_values_mv_next Project flow_values_mv_next — · 2 actors Filter · flow_values_mv_next Filter flow_values_mv_next idle · 2 actors StreamScan · flow_values_mv_next StreamScan flow_values_mv_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 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
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 18661 (Actor 160094,160095)
StreamMaterialize { columns: [party_id, account_group_type, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency], stream_key: [party_id, account_group_type], pk_columns: [party_id, account_group_type], pk_conflict: NoCheck }
├── output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, sum(flow_values_mv_next.net_value_group), sum($expr1), sum($expr2), sum(flow_values_mv_next.net_value_system), sum($expr3), sum($expr4) ]
├── stream key: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type ]
└── StreamProject { exprs: [party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, sum(flow_values_mv_next.net_value_group), sum($expr1), sum($expr2), sum(flow_values_mv_next.net_value_system), sum($expr3), sum($expr4)] }
    ├── output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, sum(flow_values_mv_next.net_value_group), sum($expr1), sum($expr2), sum(flow_values_mv_next.net_value_system), sum($expr3), sum($expr4) ]
    ├── stream key: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type ]
    └── StreamHashAgg { group_key: [party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type], aggs: [sum(flow_values_mv_next.net_value_group), sum($expr1), sum($expr2), sum(flow_values_mv_next.net_value_system), sum($expr3), sum($expr4), count] }
        ├── output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, sum(flow_values_mv_next.net_value_group), sum($expr1), sum($expr2), sum(flow_values_mv_next.net_value_system), sum($expr3), sum($expr4), count ]
        ├── stream key: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type ]
        └── StreamLocalityProvider { locality_columns: [party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type] }
            ├── output:
            │   ┌── party_to_account_groups_mv_next.party_id
            │   ├── party_to_account_groups_mv_next.type
            │   ├── flow_values_mv_next.net_value_group
            │   ├── $expr1
            │   ├── $expr2
            │   ├── flow_values_mv_next.net_value_system
            │   ├── $expr3
            │   ├── $expr4
            │   ├── flow_values_mv_next.account_group_id
            │   ├── fee_transactions_dm.transaction_id
            │   ├── flow_values_mv_next.transaction_currency
            │   ├── flow_values_mv_next.dim_transaction_date
            │   ├── flow_values_mv_next.group_currency
            │   ├── flow_values_mv_next.account_id
            │   ├── flow_values_mv_next.$expr3
            │   ├── flow_values_mv_next.transactions_dm.asset_id
            │   ├── flow_values_mv_next.asset_id
            │   ├── flow_values_mv_next.transactions_dm.transaction_type_id
            │   ├── flow_values_mv_next.transactions_dm.transaction_id
            │   ├── flow_values_mv_next.null:Int32
            │   ├── flow_values_mv_next.$src
            │   ├── flow_values_mv_next.position_type
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
            │   ├── flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
            │   ├── party_active_customer_parties_mv.party_id
            │   ├── 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.party_id
            │   ├── party_to_account_groups_mv_next.type
            │   ├── flow_values_mv_next.account_group_id
            │   ├── fee_transactions_dm.transaction_id
            │   ├── flow_values_mv_next.transaction_currency
            │   ├── flow_values_mv_next.dim_transaction_date
            │   ├── flow_values_mv_next.group_currency
            │   ├── flow_values_mv_next.account_id
            │   ├── flow_values_mv_next.$expr3
            │   ├── flow_values_mv_next.transactions_dm.asset_id
            │   ├── flow_values_mv_next.asset_id
            │   ├── flow_values_mv_next.transactions_dm.transaction_type_id
            │   ├── flow_values_mv_next.transactions_dm.transaction_id
            │   ├── flow_values_mv_next.null:Int32
            │   ├── flow_values_mv_next.$src
            │   ├── flow_values_mv_next.position_type
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
            │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
            │   ├── flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
            │   ├── party_active_customer_parties_mv.party_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.type
                │   ├── flow_values_mv_next.net_value_group
                │   ├── $expr1
                │   ├── $expr2
                │   ├── flow_values_mv_next.net_value_system
                │   ├── $expr3
                │   ├── $expr4
                │   ├── flow_values_mv_next.account_group_id
                │   ├── fee_transactions_dm.transaction_id
                │   ├── flow_values_mv_next.transaction_currency
                │   ├── flow_values_mv_next.dim_transaction_date
                │   ├── flow_values_mv_next.group_currency
                │   ├── flow_values_mv_next.account_id
                │   ├── flow_values_mv_next.$expr3
                │   ├── flow_values_mv_next.transactions_dm.asset_id
                │   ├── flow_values_mv_next.asset_id
                │   ├── flow_values_mv_next.transactions_dm.transaction_type_id
                │   ├── flow_values_mv_next.transactions_dm.transaction_id
                │   ├── flow_values_mv_next.null:Int32
                │   ├── flow_values_mv_next.$src
                │   ├── flow_values_mv_next.position_type
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
                │   ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
                │   ├── flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                │   ├── party_active_customer_parties_mv.party_id
                │   ├── 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:
                    ┌── flow_values_mv_next.account_group_id
                    ├── fee_transactions_dm.transaction_id
                    ├── flow_values_mv_next.transaction_currency
                    ├── flow_values_mv_next.dim_transaction_date
                    ├── flow_values_mv_next.group_currency
                    ├── flow_values_mv_next.account_id
                    ├── flow_values_mv_next.$expr3
                    ├── flow_values_mv_next.transactions_dm.asset_id
                    ├── flow_values_mv_next.asset_id
                    ├── flow_values_mv_next.transactions_dm.transaction_type_id
                    ├── flow_values_mv_next.transactions_dm.transaction_id
                    ├── flow_values_mv_next.null:Int32
                    ├── flow_values_mv_next.$src
                    ├── flow_values_mv_next.position_type
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
                    ├── flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
                    ├── flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
                    ├── party_active_customer_parties_mv.party_id
                    ├── party_to_account_groups_mv_next.parties.id
                    ├── party_to_account_groups_mv_next.null:Varchar
                    └── party_to_account_groups_mv_next.$src

Fragment 18662 (Actor 160097,160096)
StreamProject
└─exprs:
  ┌─party_to_account_groups_mv_next.party_id
  ├─party_to_account_groups_mv_next.type
  ├─flow_values_mv_next.net_value_group
  ├─Case((fee_transactions_dm.fee_type = 'TRANSACTIONAL':Varchar), flow_values_mv_next.net_value_group, 0:Decimal) as $expr1
  ├─Case((fee_transactions_dm.fee_type = 'NON_TRANSACTIONAL':Varchar), flow_values_mv_next.net_value_group, 0:Decimal) as $expr2
  ├─flow_values_mv_next.net_value_system
  ├─Case((fee_transactions_dm.fee_type = 'TRANSACTIONAL':Varchar), flow_values_mv_next.net_value_system, 0:Decimal) as $expr3
  ├─Case((fee_transactions_dm.fee_type = 'NON_TRANSACTIONAL':Varchar), flow_values_mv_next.net_value_system, 0:Decimal) as $expr4
  ├─flow_values_mv_next.account_group_id
  ├─fee_transactions_dm.transaction_id
  ├─flow_values_mv_next.transaction_currency
  ├─flow_values_mv_next.dim_transaction_date
  ├─flow_values_mv_next.group_currency
  ├─flow_values_mv_next.account_id
  ├─flow_values_mv_next.$expr3
  ├─flow_values_mv_next.transactions_dm.asset_id
  ├─flow_values_mv_next.asset_id
  ├─flow_values_mv_next.transactions_dm.transaction_type_id
  ├─flow_values_mv_next.transactions_dm.transaction_id
  ├─flow_values_mv_next.null:Int32
  ├─flow_values_mv_next.$src
  ├─flow_values_mv_next.position_type
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
  ├─flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─party_active_customer_parties_mv.party_id
  ├─party_to_account_groups_mv_next.parties.id
  ├─party_to_account_groups_mv_next.null:Varchar
  └─party_to_account_groups_mv_next.$src
├── output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, flow_values_mv_next.net_value_group, $expr1, $expr2, flow_values_mv_next.net_value_system, $expr3, $expr4, flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_active_customer_parties_mv.party_id, 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: [ flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_active_customer_parties_mv.party_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: [ flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_to_account_groups_mv_next.account_group_id, party_active_customer_parties_mv.party_id, 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: [ flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_active_customer_parties_mv.party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ]

Fragment 18663 (Actor 160099,160098)
StreamSyncLogStore
├── output: [ flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_to_account_groups_mv_next.account_group_id, party_active_customer_parties_mv.party_id, 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: [ flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_active_customer_parties_mv.party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ]
└── StreamHashJoin { type: Inner, predicate: flow_values_mv_next.account_group_id = party_to_account_groups_mv_next.account_group_id }
    ├── output: [ flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.type, flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_to_account_groups_mv_next.account_group_id, party_active_customer_parties_mv.party_id, 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: [ flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, party_active_customer_parties_mv.party_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: [ fee_transactions_dm.fee_type, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    │   └── stream key: [ flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    └── 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_active_customer_parties_mv.party_id, 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_active_customer_parties_mv.party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }

Fragment 18664 (Actor 160100,160101)
StreamLocalityProvider { locality_columns: [flow_values_mv_next.account_group_id] }
├── output: [ fee_transactions_dm.fee_type, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
├── stream key: [ flow_values_mv_next.account_group_id, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
└── MergeExecutor
    ├── output: [ fee_transactions_dm.fee_type, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    └── stream key: [ fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]

Fragment 18665 (Actor 160102,160103)
StreamSyncLogStore
├── output: [ fee_transactions_dm.fee_type, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
├── stream key: [ fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
└── StreamHashJoin { type: Inner, predicate: fee_transactions_dm.transaction_id = flow_values_mv_next.transaction_id }
    ├── output: [ fee_transactions_dm.fee_type, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── stream key: [ fee_transactions_dm.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── MergeExecutor { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.fee_type ], stream key: [ fee_transactions_dm.transaction_id ] }
    └── MergeExecutor
        ├── output: [ flow_values_mv_next.transaction_id, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
        └── stream key: [ flow_values_mv_next.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]

Fragment 18666 (Actor 160106,160107)
StreamTableScan { table: fee_transactions_dm, columns: [transaction_id, fee_type] } { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.fee_type ], stream key: [ fee_transactions_dm.transaction_id ] }
├── Upstream { output: [ transaction_id, fee_type ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, fee_type ], stream key: [] }

Fragment 18667 (Actor 160105,160104)
StreamLocalityProvider { locality_columns: [flow_values_mv_next.transaction_id] }
├── output: [ flow_values_mv_next.transaction_id, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
├── stream key: [ flow_values_mv_next.transaction_id, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
└── MergeExecutor
    ├── output: [ flow_values_mv_next.transaction_id, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    └── stream key: [ flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]

Fragment 18668 (Actor 160108,160109)
StreamProject
└─exprs:
  ┌─flow_values_mv_next.transaction_id
  ├─flow_values_mv_next.account_group_id
  ├─flow_values_mv_next.net_value_group
  ├─flow_values_mv_next.net_value_system
  ├─flow_values_mv_next.transaction_currency
  ├─flow_values_mv_next.dim_transaction_date
  ├─flow_values_mv_next.group_currency
  ├─flow_values_mv_next.account_id
  ├─flow_values_mv_next.$expr3
  ├─flow_values_mv_next.transactions_dm.asset_id
  ├─flow_values_mv_next.asset_id
  ├─flow_values_mv_next.transactions_dm.transaction_type_id
  ├─flow_values_mv_next.transactions_dm.transaction_id
  ├─flow_values_mv_next.null:Int32
  ├─flow_values_mv_next.$src
  ├─flow_values_mv_next.position_type
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
  └─flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
├── output: [ flow_values_mv_next.transaction_id, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
├── stream key: [ flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
└── StreamFilter { predicate: (flow_values_mv_next.transaction_type = 'FEE':Varchar) AND (flow_values_mv_next.position_type = 'POSITION':Varchar) }
    ├── output: [ flow_values_mv_next.transaction_id, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, flow_values_mv_next.transaction_type ]
    ├── stream key: [ flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    └── StreamTableScan { table: flow_values_mv_next, columns: [transaction_id, account_group_id, net_value_group, net_value_system, transaction_currency, dim_transaction_date, group_currency, account_id, $expr3, transactions_dm.asset_id, asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, position_type, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code, transaction_type] }
        ├── output: [ flow_values_mv_next.transaction_id, flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, flow_values_mv_next.transaction_type ]
        ├── stream key: [ flow_values_mv_next.transaction_currency, flow_values_mv_next.dim_transaction_date, flow_values_mv_next.group_currency, flow_values_mv_next.account_id, flow_values_mv_next.$expr3, flow_values_mv_next.transactions_dm.asset_id, flow_values_mv_next.asset_id, flow_values_mv_next.transactions_dm.transaction_type_id, flow_values_mv_next.transactions_dm.transaction_id, flow_values_mv_next.null:Int32, flow_values_mv_next.$src, flow_values_mv_next.position_type, flow_values_mv_next.account_group_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, flow_values_mv_next.account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, flow_values_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
        ├── Upstream { output: [ transaction_id, account_group_id, net_value_group, net_value_system, transaction_currency, dim_transaction_date, group_currency, account_id, $expr3, transactions_dm.asset_id, asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, position_type, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code, transaction_type ], stream key: [] }
        └── BatchPlanNode { output: [ transaction_id, account_group_id, net_value_group, net_value_system, transaction_currency, dim_transaction_date, group_currency, account_id, $expr3, transactions_dm.asset_id, asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, position_type, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code, transaction_type ], stream key: [] }

Fragment 18669 (Actor 160147,160148)
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_active_customer_parties_mv.party_id, 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_active_customer_parties_mv.party_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_active_customer_parties_mv.party_id, 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_active_customer_parties_mv.party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }

Fragment 18670 (Actor 160150,160149)
StreamSyncLogStore { 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_active_customer_parties_mv.party_id, 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_active_customer_parties_mv.party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
└── StreamHashJoin { type: Inner, predicate: party_active_customer_parties_mv.party_id = party_to_account_groups_mv_next.party_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_active_customer_parties_mv.party_id, 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_active_customer_parties_mv.party_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_active_customer_parties_mv.party_id ], stream key: [ party_active_customer_parties_mv.party_id ] }
    └── 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.party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }

Fragment 18671 (Actor 160153,160154)
StreamTableScan { table: party_active_customer_parties_mv, columns: [party_id] } { output: [ party_active_customer_parties_mv.party_id ], stream key: [ party_active_customer_parties_mv.party_id ] }
├── Upstream { output: [ party_id ], stream key: [] }
└── BatchPlanNode { output: [ party_id ], stream key: [] }

Fragment 18672 (Actor 160151,160152)
StreamLocalityProvider { locality_columns: [party_to_account_groups_mv_next.party_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.party_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 18673 (Actor 160054,160055)
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: [] }