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

← cluster alinma_bff objects client_fee_totals_mv explain
Overview Objects Graph History
materialized view · alinma_bff.client_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
41 operators
Materialize · alinma_bff.client_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 = client_to_account_gr…
— — 2 actors
HashJoin · Inner · flow_values_mv_next.account_group_id = client_to_account_gr… 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 · client_to_account_groups_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · flow_values_mv_next.transaction_id = fee_transactions_dm.tr…
— — 2 actors
HashJoin · Inner · flow_values_mv_next.transaction_id = fee_transactions_dm.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
StreamScan · fee_transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
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
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · alinma_bff.client_fee_totals_mv Materialize alinma_bff.client_fee_t… 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 = client_to_account_gr… SyncLogStore Inner · flow_values_mv_… — · 2 actors HashJoin · Inner · flow_values_mv_next.account_group_id = client_to_account_gr… 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 StreamScan · client_to_account_groups_mv StreamScan client_to_account_group… 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 · flow_values_mv_next.transaction_id = fee_transactions_dm.tr… SyncLogStore Inner · flow_values_mv_… — · 2 actors HashJoin · Inner · flow_values_mv_next.transaction_id = fee_transactions_dm.tr… HashJoin Inner · flow_values_mv_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · fee_transactions_dm StreamScan fee_transactions_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors 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
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 61589 (Actor 739524,739523)
StreamMaterialize { columns: [client_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: [client_id, account_group_type], pk_columns: [client_id, account_group_type], pk_conflict: NoCheck }
├── output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.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: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ]
└── StreamProject { exprs: [client_to_account_groups_mv.client_id, client_to_account_groups_mv.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: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.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: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ]
    └── StreamHashAgg { group_key: [client_to_account_groups_mv.client_id, client_to_account_groups_mv.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: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.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: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.type ]
        └── StreamLocalityProvider { locality_columns: [client_to_account_groups_mv.client_id, client_to_account_groups_mv.type] }
            ├── output:
            │   ┌── client_to_account_groups_mv.client_id
            │   ├── client_to_account_groups_mv.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
            │   ├── 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:Int32
            │   ├── 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: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:Int32
            │   ├── 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
            │   └── client_to_account_groups_mv.$src
            ├── stream key:
            │   ┌── client_to_account_groups_mv.client_id
            │   ├── client_to_account_groups_mv.type
            │   ├── flow_values_mv_next.account_group_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:Int32
            │   ├── 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: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:Int32
            │   ├── 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
            │   └── client_to_account_groups_mv.$src
            └── MergeExecutor
                ├── output:
                │   ┌── client_to_account_groups_mv.client_id
                │   ├── client_to_account_groups_mv.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
                │   ├── 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:Int32
                │   ├── 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: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:Int32
                │   ├── 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
                │   └── client_to_account_groups_mv.$src
                └── stream key:
                    ┌── flow_values_mv_next.account_group_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:Int32
                    ├── 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: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:Int32
                    ├── 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
                    ├── client_to_account_groups_mv.client_id
                    └── client_to_account_groups_mv.$src

Fragment 61590 (Actor 739531,739532)
StreamProject
└─exprs:
  ┌─client_to_account_groups_mv.client_id
  ├─client_to_account_groups_mv.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
  ├─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:Int32
  ├─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: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:Int32
  ├─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
  └─client_to_account_groups_mv.$src
├── output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.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, 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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.$src ]
├── stream key: [ flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ]
└── MergeExecutor
    ├── output: [ flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src ]
    └── stream key: [ flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ]

Fragment 61591 (Actor 739534,739533)
StreamSyncLogStore
├── output: [ flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src ]
├── stream key: [ flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ]
└── StreamHashJoin { type: Inner, predicate: flow_values_mv_next.account_group_id = client_to_account_groups_mv.account_group_id }
    ├── output: [ flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.type, flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src ]
    ├── stream key: [ flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ]
    ├── MergeExecutor
    │   ├── output: [ flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, 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:Int32, 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: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:Int32, 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, fee_transactions_dm.transaction_id ]
    │   └── stream key: [ flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }

Fragment 61592 (Actor 739535,739536)
StreamLocalityProvider { locality_columns: [flow_values_mv_next.account_group_id] }
├── output: [ flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, 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:Int32, 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: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:Int32, 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, fee_transactions_dm.transaction_id ]
├── stream key: [ flow_values_mv_next.account_group_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:Int32, 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: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:Int32, 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.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, 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:Int32, 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: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:Int32, 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, fee_transactions_dm.transaction_id ]
    └── 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:Int32, 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: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:Int32, 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 61593 (Actor 739538,739537)
StreamSyncLogStore
├── output: [ flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, 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:Int32, 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: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:Int32, 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, fee_transactions_dm.transaction_id ]
├── 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:Int32, 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: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:Int32, 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: flow_values_mv_next.transaction_id = fee_transactions_dm.transaction_id }
    ├── output: [ flow_values_mv_next.account_group_id, flow_values_mv_next.net_value_group, flow_values_mv_next.net_value_system, fee_transactions_dm.fee_type, 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:Int32, 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: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:Int32, 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, fee_transactions_dm.transaction_id ]
    ├── 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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 ] }

Fragment 61594 (Actor 739544,739543)
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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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 61595 (Actor 739546,739545)
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:Int32
  ├─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: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:Int32
  ├─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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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 61596 (Actor 739548,739547)
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 61597 (Actor 739555,739556)
StreamLocalityProvider { locality_columns: [client_to_account_groups_mv.account_group_id] } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }

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