position_values_mv · explain

← cluster insights objects position_values_mv explain
Overview Objects Graph History
materialized view · insights.position_values_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
Heat tree Operator graph
44 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
Project · (holding_values_mv.dim_value_date >= account_to_account_gro…
— — 2 actors
Filter · (holding_values_mv.dim_value_date >= account_to_account_gro…
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
Filter · account_to_account_groups_binned_mv
0% idle 2 actors
StreamScan · account_to_account_groups_binned_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · 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
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.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 24341 (Actor 112633,112634)
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
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src(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.dim_value_date(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.type(hidden)
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code(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.account_to_account_groups_mv_next.open_accounts_mv.account_id(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1(hidden)
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden)
│ └─$expr2(hidden)
├─stream_key:
│ ┌─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
│ ├─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.dim_value_date
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.type
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│ ├─holding_values_mv.$src
│ ├─asset_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src
│ ├─account_group_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src
│ ├─account_id
│ ├─$expr2
│ ├─holding_currency
│ ├─group_currency
│ └─dim_value_date
├─pk_columns:
│ ┌─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
│ ├─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.dim_value_date
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.type
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
│ ├─holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
│ ├─holding_values_mv.$src
│ ├─asset_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src
│ ├─account_group_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
│ ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src
│ ├─account_id
│ ├─$expr2
│ ├─holding_currency
│ ├─group_currency
│ └─dim_value_date
└─pk_conflict: NoCheck
├── output: [ holding_values_mv.account_id, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.source_entity_type, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, account_to_account_groups_binned_mv.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, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ]
├── stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2, holding_values_mv.currency_code, account_to_account_groups_binned_mv.base_currency, holding_values_mv.dim_value_date ]
└── StreamProject
└─exprs:
  ┌─holding_values_mv.account_id
  ├─holding_values_mv.asset_id
  ├─account_to_account_groups_binned_mv.account_group_id
  ├─account_to_account_groups_binned_mv.source_entity_type
  ├─holding_values_mv.dim_value_date
  ├─holding_values_mv.type
  ├─holding_values_mv.currency_code
  ├─account_to_account_groups_binned_mv.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
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
  ├─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.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─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.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src
  └─$expr2
    ├── output: [ holding_values_mv.account_id, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.source_entity_type, holding_values_mv.dim_value_date, holding_values_mv.type, holding_values_mv.currency_code, account_to_account_groups_binned_mv.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, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ]
    ├── stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2, holding_values_mv.currency_code, account_to_account_groups_binned_mv.base_currency, holding_values_mv.dim_value_date ]
    └── 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.account_group_id
  ├─account_to_account_groups_binned_mv.base_currency
  ├─account_to_account_groups_binned_mv.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.base_currency), 1:Int32, null:Int32)::Decimal) as $expr3
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
  ├─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.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─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.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src
  └─$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, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.source_entity_type, foreign_exchange_rates_eod_ft.rate, $expr3, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ]
        ├── stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2, holding_values_mv.currency_code, account_to_account_groups_binned_mv.base_currency, holding_values_mv.dim_value_date ]
        └── StreamFilter { predicate: (Not(IsNull(foreign_exchange_rates_eod_ft.rate)) OR (holding_values_mv.currency_code = account_to_account_groups_binned_mv.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.account_group_id, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.source_entity_type, foreign_exchange_rates_eod_ft.rate, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2, 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.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2, holding_values_mv.currency_code, account_to_account_groups_binned_mv.base_currency, holding_values_mv.dim_value_date ] }
            └── 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.account_group_id, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.source_entity_type, foreign_exchange_rates_eod_ft.rate, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2, 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.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2, holding_values_mv.currency_code, account_to_account_groups_binned_mv.base_currency, holding_values_mv.dim_value_date ] }

Fragment 24342 (Actor 112631,112632)
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.account_group_id, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.source_entity_type, foreign_exchange_rates_eod_ft.rate, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2, 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.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2, holding_values_mv.currency_code, account_to_account_groups_binned_mv.base_currency, holding_values_mv.dim_value_date ] }
└── StreamHashJoin { type: LeftOuter, predicate: holding_values_mv.currency_code = foreign_exchange_rates_eod_ft.source_currency_code AND account_to_account_groups_binned_mv.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.account_group_id, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.source_entity_type, foreign_exchange_rates_eod_ft.rate, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2, 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.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2, holding_values_mv.currency_code, account_to_account_groups_binned_mv.base_currency, holding_values_mv.dim_value_date ] }
    ├── 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.account_group_id, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.source_entity_type, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, $expr2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv.dim_value_month ], stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2 ] }
    └── 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 24343 (Actor 112636,112635)
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.account_group_id
  ├─account_to_account_groups_binned_mv.base_currency
  ├─account_to_account_groups_binned_mv.source_entity_type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
  ├─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.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─holding_values_mv.$src
  ├─$expr2
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_binned_mv.account_id
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src
  └─account_to_account_groups_binned_mv.dim_value_month
├── 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.account_group_id, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.source_entity_type, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, $expr2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv.dim_value_month ]
├── stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2 ]
└── StreamFilter { predicate: (holding_values_mv.dim_value_date >= account_to_account_groups_binned_mv.effective_start_date) AND (IsNull(account_to_account_groups_binned_mv.effective_end_date) OR (holding_values_mv.dim_value_date < account_to_account_groups_binned_mv.effective_end_date)) AND (IsNull(account_to_account_groups_binned_mv.opening_date) OR (holding_values_mv.dim_value_date >= account_to_account_groups_binned_mv.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, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.effective_start_date, account_to_account_groups_binned_mv.effective_end_date, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.opening_date, account_to_account_groups_binned_mv.source_entity_type, account_to_account_groups_binned_mv.dim_value_month, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2 ] }
    └── 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.effective_start_date, account_to_account_groups_binned_mv.effective_end_date, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.opening_date, account_to_account_groups_binned_mv.source_entity_type, account_to_account_groups_binned_mv.dim_value_month, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2 ] }

Fragment 24344 (Actor 112637,112638)
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, $expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.effective_start_date, account_to_account_groups_binned_mv.effective_end_date, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.opening_date, account_to_account_groups_binned_mv.source_entity_type, account_to_account_groups_binned_mv.dim_value_month, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2 ] }
└── StreamHashJoin { type: Inner, predicate: holding_values_mv.account_id = account_to_account_groups_binned_mv.account_id AND $expr2 = account_to_account_groups_binned_mv.dim_value_month } { 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.effective_start_date, account_to_account_groups_binned_mv.effective_end_date, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.opening_date, account_to_account_groups_binned_mv.source_entity_type, account_to_account_groups_binned_mv.dim_value_month, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv.account_id, $expr2 ] }
    ├── 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id ] }
    └── MergeExecutor { output: [ account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.effective_start_date, account_to_account_groups_binned_mv.effective_end_date, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.opening_date, account_to_account_groups_binned_mv.source_entity_type, account_to_account_groups_binned_mv.dim_value_month, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv.dim_value_month ] }

Fragment 24345 (Actor 112642,112641)
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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum
  ├─holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
  ├─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.dim_value_date
  ├─holding_values_mv.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv.holding_values_with_accruals_mv_next.currency_code
  ├─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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id ] }
└── 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id ] }

Fragment 24346 (Actor 112640,112639)
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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id ] }
└── 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv.$src, holding_values_mv.asset_id ] }
    ├── 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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 24347 (Actor 112644,112643)
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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.dim_value_date, holding_values_mv.holding_values_with_accruals_mv_next.type, holding_values_mv.holding_values_with_accruals_mv_next.currency_code, 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, 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.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src ], stream key: [] }

Fragment 24348 (Actor 112628,112627)
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 24349 (Actor 112629,112630)
StreamFilter { predicate: (account_to_account_groups_binned_mv.source_entity_type <> 'user':Varchar) } { output: [ account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.effective_start_date, account_to_account_groups_binned_mv.effective_end_date, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.opening_date, account_to_account_groups_binned_mv.source_entity_type, account_to_account_groups_binned_mv.dim_value_month, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv.dim_value_month ] }
└── StreamTableScan { table: account_to_account_groups_binned_mv, 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src] } { output: [ account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.effective_start_date, account_to_account_groups_binned_mv.effective_end_date, account_to_account_groups_binned_mv.base_currency, account_to_account_groups_binned_mv.opening_date, account_to_account_groups_binned_mv.source_entity_type, account_to_account_groups_binned_mv.dim_value_month, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_binned_mv.account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Int32, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.$src, account_to_account_groups_binned_mv.account_id, account_to_account_groups_binned_mv.account_group_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_binned_mv.account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_binned_mv.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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [] }

Fragment 24350 (Actor 112645,112646)
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: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
