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_next.id
— — 2 actors
HashJoin · LeftOuter · transactions_dm.asset_id = assets_dm_next.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_next
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_next.id SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_dm.asset_id = assets_dm_next.id HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm_next StreamScan assets_dm_next 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 25623 (Actor 127314,127315)
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_next.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_next.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_next.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_next.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_next.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 25624 (Actor 127313,127312)
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_next.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_next.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_next.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 25625 (Actor 127317,127316)
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_next.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_next.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 25626 (Actor 127318,127319)
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_next.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_next.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_next.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 25627 (Actor 127322,127323)
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_next.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_next.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_next.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_next.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 25628 (Actor 127324,127325)
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_next.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_next.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_next.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 25629 (Actor 127329,127328)
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_next.type, 'UNSPECIFIED':Varchar) as $expr2, assets_dm_next.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_next.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_next.type, assets_dm_next.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 25630 (Actor 127326,127327)
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_next.type, assets_dm_next.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_next.type, assets_dm_next.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_next.type, assets_dm_next.issue_currency_code, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, assets_dm_next.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 25631 (Actor 127331,127330)
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_next.type, assets_dm_next.issue_currency_code, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, assets_dm_next.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_next.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_next.type, assets_dm_next.issue_currency_code, transactions_dm.transaction_id, transactions_dm.transaction_type_id, null:Int32, $src, assets_dm_next.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_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code ], stream key: [ assets_dm_next.id ] }

Fragment 25632 (Actor 127333,127332)
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 25633 (Actor 127336,127337)
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 25634 (Actor 127335,127334)
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 25635 (Actor 127320,127321)
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 25636 (Actor 127357,127356)
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 25637 (Actor 127345,127344)
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 25638 (Actor 127342,127343)
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 25639 (Actor 127339,127338)
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 25640 (Actor 127347,127346)
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 25641 (Actor 127348,127349)
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 25642 (Actor 127353,127352)
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 25643 (Actor 127359,127358)
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 25644 (Actor 127350,127351)
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 25645 (Actor 127361,127360)
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 25646 (Actor 127362,127363)
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 25647 (Actor 127341,127340)
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 25648 (Actor 127364,127365)
StreamTableScan { table: assets_dm_next, columns: [id, type, issue_currency_code] } { output: [ assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code ], stream key: [ assets_dm_next.id ] }
├── Upstream { output: [ id, type, issue_currency_code ], stream key: [] }
└── BatchPlanNode { output: [ id, type, issue_currency_code ], stream key: [] }

Fragment 25649 (Actor 127367,127366)
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 25650 (Actor 127355,127354)
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 25651 (Actor 127369,127368)
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 25652 (Actor 127370,127371)
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: [] }