RWM Console cluster: risingwave-alinma.alinma-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
160 operators
Materialize · insights.flow_values_mv
0% idle 2 actors
Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa…
— — 2 actors
Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_…
— — 2 actors
HashJoin · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · foreign_exchange_rates_eod_ft
0% idle 2 actors
StreamScan · foreign_exchange_rates_eod_ft
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transa…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_…
— — 2 actors
HashJoin · LeftOuter · transactions_dm.currency_code = foreign_exchange_rates_eod_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · foreign_exchange_rates_eod_ft
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.account_id = account_to_account_groups_txn_…
— — 2 actors
HashJoin · Inner · transactions_dm.account_id = account_to_account_groups_txn_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · account_to_account_groups_txn_binned_mv_next
— — 2 actors
Filter · account_to_account_groups_txn_binned_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_txn_binned_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm.account_id = holding_values_raw_ft.account_…
— — 2 actors
HashJoin · LeftOuter · transactions_dm.account_id = holding_values_raw_ft.account_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · holding_values_raw_ft
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm.asset_id = assets_dm_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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.transaction_id = fee_transactions_dm.transa…
— — 2 actors
HashJoin · Inner · transactions_dm.transaction_id = fee_transactions_dm.transa… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · income_transactions_dm
— — 2 actors
Filter · income_transactions_dm
0% idle 2 actors
StreamScan · income_transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · fee_transactions_dm
— — 2 actors
Filter · fee_transactions_dm
0% idle 2 actors
StreamScan · fee_transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.transaction_type_id = transaction_types_dm.…
— — 2 actors
HashJoin · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · transaction_types_dm
0% idle 2 actors
StreamScan · transaction_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · transactions_dm.transaction_type_id = transaction_types_dm.…
— — 2 actors
HashJoin · Inner · transactions_dm.transaction_type_id = transaction_types_dm.… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · transaction_types_dm
0% idle 2 actors
StreamScan · transaction_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transactions_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
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 LocalityProvider LocalityProvider 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 LocalityProvider LocalityProvider idle · 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 LocalityProvider LocalityProvider 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 LocalityProvider LocalityProvider 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 LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · 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 LocalityProvider LocalityProvider 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 LocalityProvider LocalityProvider idle · 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 LocalityProvider LocalityProvider 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 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 LocalityProvider LocalityProvider idle · 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 LocalityProvider LocalityProvider idle · 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 LocalityProvider LocalityProvider idle · 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 63536 (Actor 746457,746458)
StreamMaterialize
├─columns:
│ ┌─transaction_id
│ ├─account_id
│ ├─asset_id
│ ├─account_group_id
│ ├─dim_transaction_date
│ ├─transaction_type
│ ├─transaction_currency
│ ├─position_type
│ ├─group_currency
│ ├─asset_type
│ ├─asset_currency
│ ├─net_value
│ ├─net_value_group
│ ├─net_value_system
│ ├─$expr3(hidden)
│ ├─transactions_dm.asset_id(hidden)
│ ├─transactions_dm.transaction_type_id(hidden)
│ ├─transactions_dm.transaction_id(hidden)
│ ├─null:Int32(hidden)
│ ├─$src(hidden)
│ ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id(hidden)
│ ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar(hidden)
│ ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date(hidden)
│ ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32(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: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:Int32(hidden)
│ ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1(hidden)
│ ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden)
│ └─foreign_exchange_rates_eod_ft.target_currency_code(hidden)
├─stream_key: [transaction_currency, dim_transaction_date, group_currency, account_id, $expr3, transactions_dm.asset_id, asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, position_type, account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code]
├─pk_columns: [transaction_currency, dim_transaction_date, group_currency, account_id, $expr3, transactions_dm.asset_id, asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, position_type, account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code]
└─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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
├── stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
└── 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 = 'SAR':Varchar), 1:Int32, null:Int32)::Decimal)) as $expr5
  ├─$expr3
  ├─transactions_dm.asset_id
  ├─transactions_dm.transaction_type_id
  ├─transactions_dm.transaction_id
  ├─null:Int32
  ├─$src
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
  └─foreign_exchange_rates_eod_ft.target_currency_code
    ├── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ]
    └── StreamFilter { predicate: (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (transactions_dm.currency_code = 'SAR':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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }
        └── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }

Fragment 63537 (Actor 746460,746459)
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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }
└── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ] }
    ├── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ] }

Fragment 63538 (Actor 746461,746462)
StreamLocalityProvider { locality_columns: [transactions_dm.currency_code, transactions_dm.transaction_valuation_date] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm_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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, transactions_dm.transaction_valuation_date, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 63539 (Actor 746465,746466)
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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 63540 (Actor 746464,746463)
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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    ├── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── 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 63541 (Actor 746468,746467)
StreamLocalityProvider { locality_columns: [transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm_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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.currency_code, account_to_account_groups_txn_binned_mv_next.base_currency, transactions_dm.transaction_valuation_date, transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── 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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 63542 (Actor 746469,746470)
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, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── 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 AND (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, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.base_currency, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    ├── 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.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.account_id, $expr3, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
    └── MergeExecutor { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

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

Fragment 63544 (Actor 746475,746476)
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.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, $expr2, assets_dm_next.issue_currency_code, holding_values_raw_ft.type, $expr3, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm_next.type, assets_dm_next.issue_currency_code, holding_values_raw_ft.type, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }

Fragment 63545 (Actor 746473,746474)
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.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_dm.account_id = holding_values_raw_ft.account_id AND transactions_dm.asset_id = holding_values_raw_ft.asset_id AND transactions_dm.transaction_valuation_date = holding_values_raw_ft.dim_value_date } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm_next.type, assets_dm_next.issue_currency_code, holding_values_raw_ft.type, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, holding_values_raw_ft.type ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, assets_dm_next.type, assets_dm_next.issue_currency_code, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm_next.id ], stream key: [ transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
    └── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }

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

Fragment 63547 (Actor 746479,746480)
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_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm_next.id ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_dm.asset_id = assets_dm_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_type_id, transactions_dm.transaction_id, null:Int32, $src, assets_dm_next.id ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
    ├── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ], stream key: [ transactions_dm.asset_id, transactions_dm.transaction_type_id, transactions_dm.transaction_id, null:Int32, $src ] }
    └── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code ], stream key: [ assets_dm_next.id ] }

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

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

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

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

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

Fragment 63553 (Actor 746403,746404)
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 63554 (Actor 746406,746405)
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 63555 (Actor 746498,746497)
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 63556 (Actor 746494,746493)
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 63557 (Actor 746492,746491)
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 63558 (Actor 746499,746500)
StreamLocalityProvider { locality_columns: [transactions_dm.transaction_id] } { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_id, transactions_dm.transaction_type_id ] }
└── MergeExecutor { output: [ transactions_dm.transaction_id, transactions_dm.account_id, transactions_dm.asset_id, transactions_dm.transaction_valuation_date, transactions_dm.currency_code, transactions_dm.net_value, transaction_types_dm.type, transactions_dm.transaction_type_id, transaction_types_dm.transaction_type_id ], stream key: [ transactions_dm.transaction_type_id, transactions_dm.transaction_id ] }

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

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

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

Fragment 63562 (Actor 746509,746510)
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 63563 (Actor 746529,746530)
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 63564 (Actor 746507,746508)
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 63565 (Actor 746531,746532)
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 63566 (Actor 746534,746533)
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 63567 (Actor 746496,746495)
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 63568 (Actor 746535,746536)
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 63569 (Actor 746515,746516)
StreamLocalityProvider { locality_columns: [holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }
└── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }

Fragment 63570 (Actor 746517,746518)
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 63571 (Actor 746519,746520)
StreamLocalityProvider { locality_columns: [account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month] } { output: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.effective_start_date, account_to_account_groups_txn_binned_mv_next.effective_end_date, account_to_account_groups_txn_binned_mv_next.base_currency, account_to_account_groups_txn_binned_mv_next.opening_date, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.dim_transaction_month, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── 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:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.dim_transaction_month ] }

Fragment 63572 (Actor 746524,746523)
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:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src] } { 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:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.source_entity_type ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Int32, 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: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:Int32, 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:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.source_entity_type ], stream key: [ account_to_account_groups_txn_binned_mv_next.account_id, account_to_account_groups_txn_binned_mv_next.account_group_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_txn_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Int32, 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: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:Int32, 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:Int32, 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: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:Int32, 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 63573 (Actor 746538,746537)
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 63574 (Actor 746521,746522)
StreamLocalityProvider { locality_columns: [foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date] } { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.target_currency_code ] }
└── MergeExecutor { output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ] }

Fragment 63575 (Actor 746540,746539)
StreamFilter { predicate: (foreign_exchange_rates_eod_ft.target_currency_code = 'SAR':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: [] }