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

← cluster insights objects flow_values_mv explain
Overview Objects Graph History
materialized view · insights.flow_values_mv profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
131 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
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
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
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
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
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
StreamScan · holding_values_raw_ft
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 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
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
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
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
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.
Materialize · insights.flow_values_mv Materialize insights.flow_values_mv idle · 2 actors Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa… Project (Not(IsNull(foreign_exc… — · 2 actors Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa… Filter (Not(IsNull(foreign_exc… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · foreign_exchange_rates_eod_ft Filter foreign_exchange_rates_… idle · 2 actors StreamScan · foreign_exchange_rates_eod_ft StreamScan foreign_exchange_rates_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa… Filter (Not(IsNull(foreign_exc… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · foreign_exchange_rates_eod_ft StreamScan foreign_exchange_rates_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · (transactions_dm.transaction_valuation_date >= account_to_a… Project (transactions_dm.transa… — · 2 actors Filter · (transactions_dm.transaction_valuation_date >= account_to_a… Filter (transactions_dm.transa… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · transactions_dm.account_id = account_to_account_groups_txn_… SyncLogStore Inner · transactions_dm… — · 2 actors HashJoin · Inner · transactions_dm.account_id = account_to_account_groups_txn_… HashJoin Inner · transactions_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · account_to_account_groups_txn_binned_mv_next Project account_to_account_grou… — · 2 actors Filter · account_to_account_groups_txn_binned_mv_next Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_txn_binned_mv_next StreamScan account_to_account_grou… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_dm.account_id = holding_values_raw_ft.account_… SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_dm.account_id = holding_values_raw_ft.account_… HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · holding_values_raw_ft StreamScan holding_values_raw_ft idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_dm.asset_id = assets_dm.id SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_dm.asset_id = assets_dm.id HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm StreamScan assets_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · transactions_dm.transaction_id = fee_transactions_dm.transa… SyncLogStore Inner · transactions_dm… — · 2 actors HashJoin · Inner · transactions_dm.transaction_id = fee_transactions_dm.transa… HashJoin Inner · transactions_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · income_transactions_dm Project income_transactions_dm — · 2 actors Filter · income_transactions_dm Filter income_transactions_dm idle · 2 actors StreamScan · income_transactions_dm StreamScan income_transactions_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · fee_transactions_dm Project fee_transactions_dm — · 2 actors Filter · fee_transactions_dm Filter fee_transactions_dm idle · 2 actors StreamScan · fee_transactions_dm StreamScan fee_transactions_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… SyncLogStore Inner · transactions_dm… — · 2 actors HashJoin · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… HashJoin Inner · transactions_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · transaction_types_dm Filter transaction_types_dm idle · 2 actors StreamScan · transaction_types_dm StreamScan transaction_types_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · transactions_dm StreamScan transactions_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… SyncLogStore Inner · transactions_dm… — · 2 actors HashJoin · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… HashJoin Inner · transactions_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · transaction_types_dm Filter transaction_types_dm idle · 2 actors StreamScan · transaction_types_dm StreamScan transaction_types_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · transactions_dm StreamScan transactions_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 23722 (Actor 106052,106053)
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, transactions_dm.transaction_id(hidden), transactions_dm.transaction_type_id(hidden), null:Int32(hidden), $src(hidden), transactions_dm.asset_id(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), $expr3(hidden), foreign_exchange_rates_eod_ft.target_currency_code(hidden)]
├─stream_key: [transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, asset_id, position_type, account_id, transactions_dm.asset_id, dim_transaction_date, 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_group_id, 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, $expr3, transaction_currency, group_currency, foreign_exchange_rates_eod_ft.target_currency_code]
├─pk_columns: [transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, asset_id, position_type, account_id, transactions_dm.asset_id, dim_transaction_date, 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_group_id, 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, $expr3, transaction_currency, group_currency, 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, foreign_exchange_rates_eod_ft.target_currency_code ]
├── stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, 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 = 'AED':Varchar), 1:Int32, null:Int32)::Decimal)) as $expr5
  ├─transactions_dm.transaction_id
  ├─transactions_dm.transaction_type_id
  ├─null:Int32
  ├─$src
  ├─transactions_dm.asset_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
  ├─$expr3
  └─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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.target_currency_code ]
    └── StreamFilter { predicate: (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transactions_dm.currency_code = 'AED':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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, foreign_exchange_rates_eod_ft.target_currency_code ] }

Fragment 23723 (Actor 106051,106050)
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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency ] }
    └── 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 23724 (Actor 106054,106055)
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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency ] }
└── 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency ] }

Fragment 23725 (Actor 106056,106057)
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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency ] }
└── 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr3, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3, transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency ] }
    ├── 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, $expr3, 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_id, 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 ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3 ] }
    └── 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 23726 (Actor 106059,106058)
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
  ├─transactions_dm.transaction_id
  ├─transactions_dm.transaction_type_id
  ├─null:Int32
  ├─$src
  ├─transactions_dm.asset_id
  ├─$expr3
  ├─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_id
  ├─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
├── 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, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, $expr3, 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_id, 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 ]
├── stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3 ]
└── 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3 ] }
    └── 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3 ] }

Fragment 23727 (Actor 106060,106061)
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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3 ] }
└── 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, 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_group_id, 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, $expr3 ] }
    ├── 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date ] }
    └── 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_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_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.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 23728 (Actor 106065,106064)
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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, $expr2, assets_dm.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date ] }
└── 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date ] }

Fragment 23729 (Actor 106062,106063)
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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date ] }
└── 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.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id, holding_values_raw_ft.type, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date ] }
    ├── 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_id, transactions_dm.transaction_type_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id ] }
    └── 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 23730 (Actor 106066,106067)
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_id, transactions_dm.transaction_type_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_id ] }
└── 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_id, transactions_dm.transaction_type_id, null:Int32, $src, assets_dm.id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, transactions_dm.asset_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, null:Int32, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.type, assets_dm.issue_currency_code ], stream key: [ assets_dm.id ] }

Fragment 23731 (Actor 106068,106069)
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_id, transactions_dm.transaction_type_id, null:Int32, $src ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_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_id, transactions_dm.transaction_type_id, null:Int32, 0:Int32 ], 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.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 23732 (Actor 106070,106071)
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, 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_id, transactions_dm.transaction_type_id, null:Int32, 0:Int32 ], 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_id, transactions_dm.transaction_type_id ] }

Fragment 23733 (Actor 106073,106072)
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_id, transactions_dm.transaction_type_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_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.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ 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 23734 (Actor 106048,106049)
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 23735 (Actor 106092,106093)
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 23736 (Actor 106081,106080)
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 23737 (Actor 106077,106076)
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 23738 (Actor 106075,106074)
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 23739 (Actor 106084,106085)
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_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_id, transactions_dm.transaction_type_id ] }

Fragment 23740 (Actor 106082,106083)
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_id, transactions_dm.transaction_type_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_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.transaction_type_id, transactions_dm.currency_code, transactions_dm.net_value ], stream key: [ 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 23741 (Actor 106095,106094)
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 23742 (Actor 106097,106096)
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 23743 (Actor 106086,106087)
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 23744 (Actor 106098,106099)
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 23745 (Actor 106100,106101)
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 23746 (Actor 106078,106079)
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 23747 (Actor 106102,106103)
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 23748 (Actor 106105,106104)
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 23749 (Actor 106089,106088)
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_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_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.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_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_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.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_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_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.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 23750 (Actor 106106,106107)
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 23751 (Actor 106091,106090)
StreamFilter { predicate: (foreign_exchange_rates_eod_ft.target_currency_code = 'AED':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: [] }