flow_values_mv · explain

← cluster insights objects flow_values_mv explain
Overview Objects Graph History
materialized view · insights.flow_values_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
Heat tree Operator graph
164 operators
Materialize · insights.flow_values_mv
0% idle 2 actors
Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa…
— — 2 actors
Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_…
— — 2 actors
HashJoin · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · foreign_exchange_rates_eod_ft
0% idle 2 actors
StreamScan · foreign_exchange_rates_eod_ft
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_…
— — 2 actors
HashJoin · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… 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 · foreign_exchange_rates_eod_ft
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 · (transactions_dm.transaction_valuation_date >= account_to_a…
— — 2 actors
Filter · (transactions_dm.transaction_valuation_date >= account_to_a…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.account_id = account_to_account_groups_txn_…
— — 2 actors
HashJoin · Inner · transactions_dm.account_id = account_to_account_groups_txn_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · account_to_account_groups_txn_binned_mv_next
— — 2 actors
Filter · account_to_account_groups_txn_binned_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_txn_binned_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm.account_id = holding_values_raw_ft.account_…
— — 2 actors
HashJoin · LeftOuter · transactions_dm.account_id = holding_values_raw_ft.account_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · holding_values_raw_ft
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 · LeftOuter · transactions_dm.asset_id = assets_dm.id
— — 2 actors
HashJoin · LeftOuter · transactions_dm.asset_id = assets_dm.id 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 · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.transaction_id = fee_transactions_dm.transa…
— — 2 actors
HashJoin · Inner · transactions_dm.transaction_id = fee_transactions_dm.transa… 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
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · income_transactions_dm
— — 2 actors
Filter · income_transactions_dm
0% idle 2 actors
StreamScan · income_transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · fee_transactions_dm
— — 2 actors
Filter · fee_transactions_dm
0% idle 2 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
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.transaction_type_id = transaction_types_dm.…
— — 2 actors
HashJoin · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · transaction_types_dm
0% idle 2 actors
StreamScan · transaction_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.transaction_type_id = transaction_types_dm.…
— — 2 actors
HashJoin · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · transaction_types_dm
0% idle 2 actors
StreamScan · transaction_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 18584 (Actor 159963,159962)
StreamMaterialize
├─columns: [transaction_id, account_id, asset_id, account_group_id, dim_transaction_date, transaction_type, transaction_currency, position_type, group_currency, asset_type, asset_currency, net_value, net_value_group, net_value_system, $expr3(hidden), transactions_dm.asset_id(hidden), transactions_dm.transaction_type_id(hidden), transactions_dm.transaction_id(hidden), null:Int32(hidden), $src(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1(hidden), account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden), foreign_exchange_rates_eod_ft.target_currency_code(hidden)]
├─stream_key: [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_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code]
├─pk_columns: [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_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code]
└─pk_conflict: NoCheck
├── output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, account_to_account_groups_txn_binned_mv_next.account_group_id, transactions_dm.transaction_valuation_date, transaction_types_dm.type, transactions_dm.currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.base_currency, $expr2, assets_dm.issue_currency_code, transactions_dm.net_value, $expr4, $expr5, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
├── stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
└── StreamProject
└─exprs:
  ┌─transactions_dm.transaction_id
  ├─transactions_dm.account_id
  ├─transactions_dm.asset_id
  ├─account_to_account_groups_txn_binned_mv_next.account_group_id
  ├─transactions_dm.transaction_valuation_date
  ├─transaction_types_dm.type
  ├─transactions_dm.currency_code
  ├─holding_values_raw_ft.type
  ├─account_to_account_groups_txn_binned_mv_next.base_currency
  ├─$expr2
  ├─assets_dm.issue_currency_code
  ├─transactions_dm.net_value
  ├─(transactions_dm.net_value * Coalesce(foreign_exchange_rates_eod_ft.rate, Case((transactions_dm.currency_code = account_to_account_groups_txn_binned_mv_next.base_currency), 1:Int32, null:Int32)::Decimal)) as $expr4
  ├─(transactions_dm.net_value * Coalesce(foreign_exchange_rates_eod_ft.rate, Case((transactions_dm.currency_code = 'USD':Varchar), 1:Int32, null:Int32)::Decimal)) as $expr5
  ├─$expr3
  ├─transactions_dm.asset_id
  ├─transactions_dm.transaction_type_id
  ├─transactions_dm.transaction_id
  ├─null:Int32
  ├─$src
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
  └─foreign_exchange_rates_eod_ft.target_currency_code
    ├── output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, account_to_account_groups_txn_binned_mv_next.account_group_id, transactions_dm.transaction_valuation_date, transaction_types_dm.type, transactions_dm.currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.base_currency, $expr2, assets_dm.issue_currency_code, transactions_dm.net_value, $expr4, $expr5, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
    └── StreamFilter { predicate: (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transactions_dm.currency_code = 'USD':Varchar)) } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }
        └── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }

Fragment 18585 (Actor 159960,159961)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_dm.currency_code = foreign_exchange_rates_eod_ft.source_currency_code AND transactions_dm.transaction_valuation_date = foreign_exchange_rates_eod_ft.date } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ] }

Fragment 18586 (Actor 159964,159965)
StreamLocalityProvider { locality_columns: [transactions_dm.currency_code, transactions_dm.transaction_valuation_date] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 18587 (Actor 159967,159966)
StreamFilter { predicate: (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transactions_dm.currency_code = account_to_account_groups_txn_binned_mv_next.base_currency)) } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 18588 (Actor 159969,159968)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_dm.currency_code = foreign_exchange_rates_eod_ft.source_currency_code AND account_to_account_groups_txn_binned_mv_next.base_currency = foreign_exchange_rates_eod_ft.target_currency_code AND transactions_dm.transaction_valuation_date = foreign_exchange_rates_eod_ft.date } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.rate, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }

Fragment 18589 (Actor 159970,159971)
StreamLocalityProvider { locality_columns: [transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 18590 (Actor 159974,159975)
StreamProject
└─exprs:
  ┌─transactions_dm.transaction_id
  ├─transactions_dm.account_id
  ├─transactions_dm.asset_id
  ├─transactions_dm.transaction_valuation_date
  ├─transactions_dm.currency_code
  ├─transactions_dm.net_value
  ├─transaction_types_dm.type
  ├─$expr2
  ├─assets_dm.issue_currency_code
  ├─holding_values_raw_ft.type
  ├─account_to_account_groups_txn_binned_mv_next.account_group_id
  ├─account_to_account_groups_txn_binned_mv_next.base_currency
  ├─$expr3
  ├─transactions_dm.asset_id
  ├─transactions_dm.transaction_type_id
  ├─transactions_dm.transaction_id
  ├─null:Int32
  ├─$src
  ├─account_to_account_groups_txn_binned_mv_next.account_id
  ├─account_to_account_groups_txn_binned_mv_next.dim_transaction_month
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  └─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
├── output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
├── stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
└── StreamFilter { predicate: (transactions_dm.transaction_valuation_date >= account_to_account_groups_txn_binned_mv_next.effective_start_date) AND (IsNull(account_to_account_groups_txn_binned_mv_next.effective_end_date) OR (transactions_dm.transaction_valuation_date < account_to_account_groups_txn_binned_mv_next.effective_end_date)) AND (IsNull(account_to_account_groups_txn_binned_mv_next.opening_date) OR (transactions_dm.transaction_valuation_date >= account_to_account_groups_txn_binned_mv_next.opening_date)) } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 18591 (Actor 159972,159973)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── StreamHashJoin { type: Inner, predicate: transactions_dm.account_id = account_to_account_groups_txn_binned_mv_next.account_id AND $expr3 = account_to_account_groups_txn_binned_mv_next.dim_transaction_month } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
    └── MergeExecutor { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 18592 (Actor 159977,159976)
StreamLocalityProvider { locality_columns: [transactions_dm.account_id, $expr3] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }

Fragment 18593 (Actor 159979,159978)
StreamProject { exprs: [transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, Coalesce(assets_dm.type, 'UNSPECIFIED':Varchar) as $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, AtTimeZone(DateTrunc('MONTH':Varchar, AtTimeZone(transactions_dm.transaction_valuation_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, holding_values_raw_ft.type, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }

Fragment 18594 (Actor 159981,159980)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, holding_values_raw_ft.type, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_dm.account_id = holding_values_raw_ft.account_id AND transactions_dm.asset_id = holding_values_raw_ft.asset_id AND transactions_dm.transaction_valuation_date = holding_values_raw_ft.dim_value_date } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, holding_values_raw_ft.type, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
    └── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }

Fragment 18595 (Actor 159982,159983)
StreamLocalityProvider { locality_columns: [transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }

Fragment 18596 (Actor 159984,159985)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_dm.asset_id = assets_dm.id } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm.type, assets_dm.issue_currency_code, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.type, assets_dm.issue_currency_code ], stream key: [ assets_dm.id ] }

Fragment 18597 (Actor 159986,159987)
StreamLocalityProvider { locality_columns: [transactions_dm.asset_id] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }

Fragment 18598 (Actor 159989,159988)
StreamUnion { all: true } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, 0:Int32 ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src, 1:Int32 ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, fee_transactions_dm.source_asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, $expr1, transaction_types_dm.type, transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src, 2:Int32 ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }

Fragment 18599 (Actor 159992,159993)
StreamProject { exprs: [transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, 0:Int32] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, 0:Int32 ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }

Fragment 18600 (Actor 159990,159991)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
└── StreamHashJoin { type: Inner, predicate: transactions_dm.transaction_type_id = transaction_types_dm.transaction_type_id } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
    └── MergeExecutor { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type ], stream key: [ transaction_types_dm.transaction_type_id ] }

Fragment 18601 (Actor 159995,159994)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_type_id] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_id ] }

Fragment 18602 (Actor 159997,159996)
StreamTableScan { table: transactions_dm, columns: [transaction_id, account_id, asset_id, transaction_valuation_date, transaction_type_id, currency_code, net_value] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_id ] }
├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_type_id, currency_code, net_value ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_type_id, currency_code, net_value ], stream key: [] }

Fragment 18603 (Actor 160026,160027)
StreamFilter { predicate: In(transaction_types_dm.type, 'TRADE':Varchar, 'TRANSFER':Varchar) } { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type ], stream key: [ transaction_types_dm.transaction_type_id ] }
└── StreamTableScan { table: transaction_types_dm, columns: [transaction_type_id, type] } { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type ], stream key: [ transaction_types_dm.transaction_type_id ] }
    ├── Upstream { output: [ transaction_type_id, type ], stream key: [] }
    └── BatchPlanNode { output: [ transaction_type_id, type ], stream key: [] }

Fragment 18604 (Actor 160002,160003)
StreamProject { exprs: [transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src, 1:Int32] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src, 1:Int32 ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, fee_transactions_dm.source_asset_id, transactions_dm.transaction_type_id, fee_transactions_dm.transaction_id, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }

Fragment 18605 (Actor 160006,160007)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, fee_transactions_dm.source_asset_id, transactions_dm.transaction_type_id, fee_transactions_dm.transaction_id, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, fee_transactions_dm.source_asset_id, transactions_dm.transaction_type_id, fee_transactions_dm.transaction_id, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }

Fragment 18606 (Actor 160000,160001)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, fee_transactions_dm.source_asset_id, transactions_dm.transaction_type_id, fee_transactions_dm.transaction_id, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }
└── StreamHashJoin { type: Inner, predicate: transactions_dm.transaction_id = fee_transactions_dm.transaction_id } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, fee_transactions_dm.source_asset_id, transactions_dm.transaction_type_id, fee_transactions_dm.transaction_id, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id ] }
    └── MergeExecutor { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.source_asset_id, $src ], stream key: [ fee_transactions_dm.transaction_id, $src ] }

Fragment 18607 (Actor 160009,160008)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_id] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }

Fragment 18608 (Actor 160013,160012)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }

Fragment 18609 (Actor 160010,160011)
StreamSyncLogStore { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
└── StreamHashJoin { type: Inner, predicate: transactions_dm.transaction_type_id = transaction_types_dm.transaction_type_id } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
    └── MergeExecutor { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type ], stream key: [ transaction_types_dm.transaction_type_id ] }

Fragment 18610 (Actor 160014,160015)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_type_id] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_id ] }

Fragment 18611 (Actor 160028,160029)
StreamTableScan { table: transactions_dm, columns: [transaction_id, account_id, asset_id, transaction_valuation_date, transaction_type_id, currency_code, net_value] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ transactions_dm.transaction_id ] }
├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_type_id, currency_code, net_value ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_type_id, currency_code, net_value ], stream key: [] }

Fragment 18612 (Actor 160030,160031)
StreamFilter { predicate: In(transaction_types_dm.type, 'INCOME':Varchar, 'FEE':Varchar) } { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type ], stream key: [ transaction_types_dm.transaction_type_id ] }
└── StreamTableScan { table: transaction_types_dm, columns: [transaction_type_id, type] } { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type ], stream key: [ transaction_types_dm.transaction_type_id ] }
    ├── Upstream { output: [ transaction_type_id, type ], stream key: [] }
    └── BatchPlanNode { output: [ transaction_type_id, type ], stream key: [] }

Fragment 18613 (Actor 160017,160016)
StreamUnion { all: true } { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.source_asset_id, $src ], stream key: [ fee_transactions_dm.transaction_id, $src ] }
├── MergeExecutor { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.source_asset_id, 0:Int32 ], stream key: [ fee_transactions_dm.transaction_id ] }
└── MergeExecutor { output: [ income_transactions_dm.transaction_id, income_transactions_dm.source_asset_id, 1:Int32 ], stream key: [ income_transactions_dm.transaction_id ] }

Fragment 18614 (Actor 160033,160032)
StreamProject { exprs: [fee_transactions_dm.transaction_id, fee_transactions_dm.source_asset_id, 0:Int32] } { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.source_asset_id, 0:Int32 ], stream key: [ fee_transactions_dm.transaction_id ] }
└── StreamFilter { predicate: Not(IsNull(fee_transactions_dm.source_account_id)) AND Not(IsNull(fee_transactions_dm.source_asset_id)) } { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id ], stream key: [ fee_transactions_dm.transaction_id ] }
    └── StreamTableScan { table: fee_transactions_dm, columns: [transaction_id, source_asset_id, source_account_id] } { output: [ fee_transactions_dm.transaction_id, fee_transactions_dm.source_asset_id, fee_transactions_dm.source_account_id ], stream key: [ fee_transactions_dm.transaction_id ] }
        ├── Upstream { output: [ transaction_id, source_asset_id, source_account_id ], stream key: [] }
        └── BatchPlanNode { output: [ transaction_id, source_asset_id, source_account_id ], stream key: [] }

Fragment 18615 (Actor 160034,160035)
StreamProject { exprs: [income_transactions_dm.transaction_id, income_transactions_dm.source_asset_id, 1:Int32] } { output: [ income_transactions_dm.transaction_id, income_transactions_dm.source_asset_id, 1:Int32 ], stream key: [ income_transactions_dm.transaction_id ] }
└── StreamFilter { predicate: Not(IsNull(income_transactions_dm.source_account_id)) AND Not(IsNull(income_transactions_dm.source_asset_id)) } { output: [ income_transactions_dm.transaction_id, income_transactions_dm.source_asset_id, income_transactions_dm.source_account_id ], stream key: [ income_transactions_dm.transaction_id ] }
    └── StreamTableScan { table: income_transactions_dm, columns: [transaction_id, source_asset_id, source_account_id] } { output: [ income_transactions_dm.transaction_id, income_transactions_dm.source_asset_id, income_transactions_dm.source_account_id ], stream key: [ income_transactions_dm.transaction_id ] }
        ├── Upstream { output: [ transaction_id, source_asset_id, source_account_id ], stream key: [] }
        └── BatchPlanNode { output: [ transaction_id, source_asset_id, source_account_id ], stream key: [] }

Fragment 18616 (Actor 160004,160005)
StreamProject { exprs: [transactions_dm.transaction_id, transactions_dm.account_id, fee_transactions_dm.source_asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, Neg(transactions_dm.net_value) as $expr1, transaction_types_dm.type, transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src, 2:Int32] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, fee_transactions_dm.source_asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, $expr1, transaction_types_dm.type, transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src, 2:Int32 ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, fee_transactions_dm.source_asset_id, transactions_dm.transaction_type_id, fee_transactions_dm.transaction_id, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, $src ] }

Fragment 18617 (Actor 160036,160037)
StreamTableScan { table: assets_dm, columns: [id, type, issue_currency_code] } { output: [ assets_dm.id, assets_dm.type, assets_dm.issue_currency_code ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, type, issue_currency_code ], stream key: [] }
└── BatchPlanNode { output: [ id, type, issue_currency_code ], stream key: [] }

Fragment 18618 (Actor 160018,160019)
StreamLocalityProvider { locality_columns: [holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }
└── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }

Fragment 18619 (Actor 160039,160038)
StreamTableScan { table: holding_values_raw_ft, columns: [account_id, asset_id, dim_value_date, type] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }
├── Upstream { output: [ account_id, asset_id, dim_value_date, type ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, dim_value_date, type ], stream key: [] }

Fragment 18620 (Actor 160020,160021)
StreamLocalityProvider { locality_columns: [account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month] } { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.dim_transaction_month ] }

Fragment 18621 (Actor 160024,160025)
StreamProject { exprs: [account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src] } { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.dim_transaction_month ] }
└── StreamFilter { predicate: (account_to_account_groups_txn_binned_mv_next.source_entity_type <> 'user':Varchar) } { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.source_entity_type ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.dim_transaction_month ] }
    └── StreamTableScan { table: account_to_account_groups_txn_binned_mv_next, columns: [account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, dim_transaction_month, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, source_entity_type] } { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.source_entity_type ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.dim_transaction_month ] }
        ├── Upstream { output: [ account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, dim_transaction_month, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, source_entity_type ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, dim_transaction_month, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, source_entity_type ], stream key: [] }

Fragment 18622 (Actor 160041,160040)
StreamTableScan { table: foreign_exchange_rates_eod_ft, columns: [source_currency_code, target_currency_code, date, rate] } { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }
├── Upstream { output: [ source_currency_code, target_currency_code, date, rate ], stream key: [] }
└── BatchPlanNode { output: [ source_currency_code, target_currency_code, date, rate ], stream key: [] }

Fragment 18623 (Actor 160022,160023)
StreamLocalityProvider { locality_columns: [foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date] } { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ] }
└── MergeExecutor { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }

Fragment 18624 (Actor 160042,160043)
StreamFilter { predicate: (foreign_exchange_rates_eod_ft.target_currency_code = 'USD':Varchar) } { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }
└── StreamTableScan { table: foreign_exchange_rates_eod_ft, columns: [source_currency_code, date, rate, target_currency_code] } { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }
    ├── Upstream { output: [ source_currency_code, date, rate, target_currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ source_currency_code, date, rate, target_currency_code ], stream key: [] }
RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local
