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

← cluster insights objects position_values_mv explain
Overview Objects Graph History
materialized view · insights.position_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
52 operators
Materialize · insights.position_values_mv
0% idle 2 actors
Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holdin…
— — 2 actors
Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holdin…
— — 2 actors
Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holdin…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · holding_values_mv.currency_code = foreign_exchange_rates_eo…
— — 2 actors
HashJoin · LeftOuter · holding_values_mv.currency_code = foreign_exchange_rates_eo… 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 · holding_values_mv.account_id = account_to_account_groups_bi…
— — 2 actors
HashJoin · Inner · holding_values_mv.account_id = account_to_account_groups_bi… 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 · account_to_account_groups_binned_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_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 · holding_values_mv.asset_id = assets_dm.id
— — 2 actors
HashJoin · LeftOuter · holding_values_mv.asset_id = assets_dm.id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · holding_values_mv
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.position_values_mv Materialize insights.position_value… idle · 2 actors Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holdin… Project (Not(IsNull(foreign_exc… — · 2 actors Project · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holdin… Project (Not(IsNull(foreign_exc… — · 2 actors Filter · (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holdin… Filter (Not(IsNull(foreign_exc… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · holding_values_mv.currency_code = foreign_exchange_rates_eo… SyncLogStore LeftOuter · holding_val… — · 2 actors HashJoin · LeftOuter · holding_values_mv.currency_code = foreign_exchange_rates_eo… HashJoin LeftOuter · holding_val… 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 · holding_values_mv.account_id = account_to_account_groups_bi… SyncLogStore Inner · holding_values_… — · 2 actors HashJoin · Inner · holding_values_mv.account_id = account_to_account_groups_bi… HashJoin Inner · holding_values_… 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 · account_to_account_groups_binned_mv_next Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_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 · holding_values_mv.asset_id = assets_dm.id SyncLogStore LeftOuter · holding_val… — · 2 actors HashJoin · LeftOuter · holding_values_mv.asset_id = assets_dm.id HashJoin LeftOuter · holding_val… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm StreamScan assets_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · holding_values_mv StreamScan holding_values_mv 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 61295 (Actor 738680,738681)
StreamMaterialize
├─columns:
│ ┌─account_id
│ ├─asset_id
│ ├─account_group_id
│ ├─source_entity_type
│ ├─dim_value_date
│ ├─position_type
│ ├─holding_currency
│ ├─group_currency
│ ├─asset_currency
│ ├─asset_type
│ ├─market_value_holding
│ ├─average_cost_holding
│ ├─purchased_quantity
│ ├─fair_value_holding
│ ├─accrued_value
│ ├─fx_rate_to_group
│ ├─market_value_group
│ ├─average_cost_group
│ ├─fair_value_group
│ ├─accrued_value_group
│ ├─relationship_value_group
│ ├─fair_relationship_value_group
│ ├─market_value_system
│ ├─average_cost_system
│ ├─fair_value_system
│ ├─accrued_value_system
│ ├─relationship_value_system
│ ├─fair_relationship_value_system
│ ├─$expr2(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.account_id(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.asset_id(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.type(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code(hidden)
│ ├─holding_values_mv.$src(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32(hidden)
│ ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1(hidden)
│ └─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden)
├─stream_key: [holding_currency, group_currency, dim_value_date, account_id, $expr2, asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src]
├─pk_columns: [holding_currency, group_currency, dim_value_date, account_id, $expr2, asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src]
└─pk_conflict: NoCheck
├── output: [ holding_values_mv.account_id, holding_values_mv.asset_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.source_entity_type, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, assets_dm.issue_currency_code, $expr1, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, $expr3, $expr4, $expr5, $expr6, $expr7, $expr8, $expr9, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, $expr10, $expr11, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
├── stream key: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
└── StreamProject
└─exprs:
  ┌─holding_values_mv.account_id
  ├─holding_values_mv.asset_id
  ├─account_to_account_groups_binned_mv_next.account_group_id
  ├─account_to_account_groups_binned_mv_next.source_entity_type
  ├─holding_values_mv.dim_value_date
  ├─holding_values_mv.type
  ├─holding_values_mv.currency_code
  ├─account_to_account_groups_binned_mv_next.base_currency
  ├─assets_dm.issue_currency_code
  ├─$expr1
  ├─holding_values_mv.market_value
  ├─holding_values_mv.average_cost
  ├─holding_values_mv.purchased_quantity
  ├─holding_values_mv.fair_value
  ├─holding_values_mv.accrued_value
  ├─$expr3
  ├─(holding_values_mv.market_value * $expr3) as $expr4
  ├─(holding_values_mv.average_cost * $expr3) as $expr5
  ├─(holding_values_mv.fair_value * $expr3) as $expr6
  ├─(holding_values_mv.accrued_value * $expr3) as $expr7
  ├─(Abs(holding_values_mv.market_value) * $expr3) as $expr8
  ├─(Abs(holding_values_mv.fair_value) * $expr3) as $expr9
  ├─holding_values_mv.market_value_system_currency
  ├─holding_values_mv.average_cost_system_currency
  ├─holding_values_mv.fair_value_system_currency
  ├─holding_values_mv.accrued_value_system_currency
  ├─Abs(holding_values_mv.market_value_system_currency) as $expr10
  ├─Abs(holding_values_mv.fair_value_system_currency) as $expr11
  ├─$expr2
  ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.account_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─holding_values_mv.$src
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  └─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
    ├── output: [ holding_values_mv.account_id, holding_values_mv.asset_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.source_entity_type, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, assets_dm.issue_currency_code, $expr1, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, $expr3, $expr4, $expr5, $expr6, $expr7, $expr8, $expr9, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, $expr10, $expr11, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    ├── stream key: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
    └── StreamProject
└─exprs:
  ┌─holding_values_mv.account_id
  ├─holding_values_mv.asset_id
  ├─holding_values_mv.dim_value_date
  ├─holding_values_mv.type
  ├─holding_values_mv.currency_code
  ├─holding_values_mv.market_value
  ├─holding_values_mv.average_cost
  ├─holding_values_mv.purchased_quantity
  ├─holding_values_mv.fair_value
  ├─holding_values_mv.accrued_value
  ├─holding_values_mv.market_value_system_currency
  ├─holding_values_mv.average_cost_system_currency
  ├─holding_values_mv.fair_value_system_currency
  ├─holding_values_mv.accrued_value_system_currency
  ├─assets_dm.issue_currency_code
  ├─$expr1
  ├─account_to_account_groups_binned_mv_next.account_group_id
  ├─account_to_account_groups_binned_mv_next.base_currency
  ├─account_to_account_groups_binned_mv_next.source_entity_type
  ├─foreign_exchange_rates_eod_ft.rate
  ├─Coalesce(foreign_exchange_rates_eod_ft.rate, Case((holding_values_mv.currency_code = account_to_account_groups_binned_mv_next.base_currency), 1:Int32, null:Int32)::Decimal) as $expr3
  ├─$expr2
  ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.account_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─holding_values_mv.$src
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  └─account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src
        ├── output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, foreign_exchange_rates_eod_ft.rate, $expr3, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
        ├── stream key: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ]
        └── StreamFilter { predicate: (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holding_values_mv.currency_code = account_to_account_groups_binned_mv_next.base_currency)) } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, foreign_exchange_rates_eod_ft.rate, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_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: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
            └── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, foreign_exchange_rates_eod_ft.rate, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_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: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 61296 (Actor 738678,738679)
StreamSyncLogStore { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, foreign_exchange_rates_eod_ft.rate, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_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: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: holding_values_mv.currency_code = foreign_exchange_rates_eod_ft.source_currency_code AND account_to_account_groups_binned_mv_next.base_currency = foreign_exchange_rates_eod_ft.target_currency_code AND holding_values_mv.dim_value_date = foreign_exchange_rates_eod_ft.date } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, foreign_exchange_rates_eod_ft.rate, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_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: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    ├── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_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 61297 (Actor 738682,738683)
StreamLocalityProvider { locality_columns: [holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date] } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.currency_code, account_to_account_groups_binned_mv_next.base_currency, holding_values_mv.dim_value_date, holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 61298 (Actor 738685,738684)
StreamSyncLogStore { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── StreamHashJoin { type: Inner, predicate: holding_values_mv.account_id = account_to_account_groups_binned_mv_next.account_id AND $expr2 = account_to_account_groups_binned_mv_next.dim_value_month AND (holding_values_mv.dim_value_date >= account_to_account_groups_binned_mv_next.effective_start_date) AND (IsNull(account_to_account_groups_binned_mv_next.effective_end_date) OR (holding_values_mv.dim_value_date < account_to_account_groups_binned_mv_next.effective_end_date)) AND (IsNull(account_to_account_groups_binned_mv_next.opening_date) OR (holding_values_mv.dim_value_date >= account_to_account_groups_binned_mv_next.opening_date)) } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.source_entity_type, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    ├── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
    └── MergeExecutor { output: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.effective_start_date, account_to_account_groups_binned_mv_next.effective_end_date, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.opening_date, account_to_account_groups_binned_mv_next.source_entity_type, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 61299 (Actor 738768,738769)
StreamLocalityProvider { locality_columns: [holding_values_mv.account_id, $expr2] } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.account_id, $expr2, holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
└── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }

Fragment 61300 (Actor 738773,738772)
StreamProject { exprs: [holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, Coalesce(assets_dm.type, 'UNSPECIFIED':Varchar) as $expr1, AtTimeZone(DateTrunc('MONTH':Varchar, AtTimeZone(holding_values_mv.dim_value_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src] } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.accrued_value_system_currency, assets_dm.issue_currency_code, $expr1, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
└── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.accrued_value_system_currency, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, assets_dm.type, assets_dm.issue_currency_code, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, assets_dm.id ], stream key: [ holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }

Fragment 61301 (Actor 738770,738771)
StreamSyncLogStore { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.accrued_value_system_currency, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, assets_dm.type, assets_dm.issue_currency_code, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, assets_dm.id ], stream key: [ holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: holding_values_mv.asset_id = assets_dm.id } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.accrued_value_system_currency, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, assets_dm.type, assets_dm.issue_currency_code, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, assets_dm.id ], stream key: [ holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
    ├── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.accrued_value_system_currency, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.type, assets_dm.issue_currency_code ], stream key: [ assets_dm.id ] }

Fragment 61302 (Actor 738775,738774)
StreamLocalityProvider { locality_columns: [holding_values_mv.asset_id] } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.accrued_value_system_currency, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
└── MergeExecutor { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.accrued_value_system_currency, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }

Fragment 61303 (Actor 738792,738791)
StreamTableScan { table: holding_values_mv, columns: [account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src] } { output: [ holding_values_mv.account_id, holding_values_mv.asset_id, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, holding_values_mv.market_value, holding_values_mv.average_cost, holding_values_mv.purchased_quantity, holding_values_mv.fair_value, holding_values_mv.accrued_value, holding_values_mv.accrued_value_system_currency, holding_values_mv.market_value_system_currency, holding_values_mv.average_cost_system_currency, holding_values_mv.fair_value_system_currency, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ], stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src ] }
├── Upstream { output: [ account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src ], stream key: [] }

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

Fragment 61305 (Actor 738777,738776)
StreamLocalityProvider { locality_columns: [account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month] } { output: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.effective_start_date, account_to_account_groups_binned_mv_next.effective_end_date, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.opening_date, account_to_account_groups_binned_mv_next.source_entity_type, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.effective_start_date, account_to_account_groups_binned_mv_next.effective_end_date, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.opening_date, account_to_account_groups_binned_mv_next.source_entity_type, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.dim_value_month ] }

Fragment 61306 (Actor 738779,738778)
StreamFilter { predicate: (account_to_account_groups_binned_mv_next.source_entity_type <> 'user':Varchar) } { output: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.effective_start_date, account_to_account_groups_binned_mv_next.effective_end_date, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.opening_date, account_to_account_groups_binned_mv_next.source_entity_type, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.dim_value_month ] }
└── StreamTableScan { table: account_to_account_groups_binned_mv_next, columns: [account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, dim_value_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] } { output: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.effective_start_date, account_to_account_groups_binned_mv_next.effective_end_date, account_to_account_groups_binned_mv_next.base_currency, account_to_account_groups_binned_mv_next.opening_date, account_to_account_groups_binned_mv_next.source_entity_type, account_to_account_groups_binned_mv_next.dim_value_month, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv_next.account_id, account_to_account_groups_binned_mv_next.account_group_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv_next.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv_next.dim_value_month ] }
    ├── Upstream { output: [ account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, dim_value_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 ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, dim_value_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 ], stream key: [] }

Fragment 61307 (Actor 738781,738780)
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: [] }