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

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

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
181 operators
Materialize · alinma_bff.book_of_business_accounts_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = structured_deposit_accounts_dm.acc…
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = structured_deposit_accounts_dm.acc… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · structured_deposit_accounts_dm
— — 2 actors
Filter · structured_deposit_accounts_dm
0% idle 2 actors
StreamScan · structured_deposit_accounts_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = fixed_deposit_accounts_dm.account_…
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = fixed_deposit_accounts_dm.account_… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · fixed_deposit_accounts_dm
— — 2 actors
Filter · fixed_deposit_accounts_dm
0% idle 2 actors
StreamScan · fixed_deposit_accounts_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = financing_accounts_dm.account_id
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = financing_accounts_dm.account_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
Project · financing_accounts_dm
— — 2 actors
Filter · financing_accounts_dm
0% idle 2 actors
StreamScan · financing_accounts_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = credit_card_accounts_dm.account_id
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = credit_card_accounts_dm.account_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
Project · credit_card_accounts_dm
— — 2 actors
Filter · credit_card_accounts_dm
0% idle 2 actors
StreamScan · credit_card_accounts_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = account_latest_facts_mv.account_id
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = account_latest_facts_mv.account_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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · account_latest_facts_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · $expr1 = position_snapshot_mv_next.account_group_id AND acc…
— — 2 actors
HashJoin · LeftOuter · $expr1 = position_snapshot_mv_next.account_group_id AND acc… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · position_snapshot_mv_next
— — 2 actors
Filter · position_snapshot_mv_next
0% idle 2 actors
StreamScan · position_snapshot_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = account_reference_identifiers_mv.a…
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = account_reference_identifiers_mv.a… 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 · account_reference_identifiers_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = account_task_counts_mv.account_id
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = account_task_counts_mv.account_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 · account_task_counts_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = account_portfolios_mv.account_id
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = account_portfolios_mv.account_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 · account_portfolios_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm.account_id = account_owners_mv.account_id
— — 2 actors
HashJoin · LeftOuter · accounts_dm.account_id = account_owners_mv.account_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 · account_owners_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · accounts_dm.base_currency_code = currencies_dm.code, nested…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · currencies_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · accounts_dm.status_label_id = labels_dm.label_id, nested_lo…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · labels_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · accounts_dm.product_type_id = product_types_dm.product_type…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · product_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · accounts_dm
— — 2 actors
Filter · accounts_dm
0% idle 2 actors
StreamScan · accounts_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · alinma_bff.book_of_business_accounts_mv Materialize alinma_bff.book_of_busi… idle · 2 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = structured_deposit_accounts_dm.acc… SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = structured_deposit_accounts_dm.acc… HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · structured_deposit_accounts_dm Project structured_deposit_acco… — · 2 actors Filter · structured_deposit_accounts_dm Filter structured_deposit_acco… idle · 2 actors StreamScan · structured_deposit_accounts_dm StreamScan structured_deposit_acco… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = fixed_deposit_accounts_dm.account_… SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = fixed_deposit_accounts_dm.account_… HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · fixed_deposit_accounts_dm Project fixed_deposit_accounts_… — · 2 actors Filter · fixed_deposit_accounts_dm Filter fixed_deposit_accounts_… idle · 2 actors StreamScan · fixed_deposit_accounts_dm StreamScan fixed_deposit_accounts_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = financing_accounts_dm.account_id SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = financing_accounts_dm.account_id HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · financing_accounts_dm Project financing_accounts_dm — · 2 actors Filter · financing_accounts_dm Filter financing_accounts_dm idle · 2 actors StreamScan · financing_accounts_dm StreamScan financing_accounts_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = credit_card_accounts_dm.account_id SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = credit_card_accounts_dm.account_id HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · credit_card_accounts_dm Project credit_card_accounts_dm — · 2 actors Filter · credit_card_accounts_dm Filter credit_card_accounts_dm idle · 2 actors StreamScan · credit_card_accounts_dm StreamScan credit_card_accounts_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = account_latest_facts_mv.account_id SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = account_latest_facts_mv.account_id HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · account_latest_facts_mv StreamScan account_latest_facts_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · $expr1 = position_snapshot_mv_next.account_group_id AND acc… SyncLogStore LeftOuter · $expr1 = po… — · 2 actors HashJoin · LeftOuter · $expr1 = position_snapshot_mv_next.account_group_id AND acc… HashJoin LeftOuter · $expr1 = po… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · position_snapshot_mv_next Project position_snapshot_mv_ne… — · 2 actors Filter · position_snapshot_mv_next Filter position_snapshot_mv_ne… idle · 2 actors StreamScan · position_snapshot_mv_next StreamScan position_snapshot_mv_ne… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = account_reference_identifiers_mv.a… SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = account_reference_identifiers_mv.a… HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · account_reference_identifiers_mv StreamScan account_reference_ident… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = account_task_counts_mv.account_id SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = account_task_counts_mv.account_id HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · account_task_counts_mv StreamScan account_task_counts_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = account_portfolios_mv.account_id SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = account_portfolios_mv.account_id HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · account_portfolios_mv StreamScan account_portfolios_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm.account_id = account_owners_mv.account_id SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm.account_id = account_owners_mv.account_id HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · account_owners_mv StreamScan account_owners_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors TemporalJoin · LeftOuter · accounts_dm.base_currency_code = currencies_dm.code, nested… TemporalJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · currencies_dm StreamScan currencies_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors TemporalJoin · LeftOuter · accounts_dm.status_label_id = labels_dm.label_id, nested_lo… TemporalJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · labels_dm StreamScan labels_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors TemporalJoin · LeftOuter · accounts_dm.product_type_id = product_types_dm.product_type… TemporalJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · product_types_dm StreamScan product_types_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · accounts_dm Project accounts_dm — · 2 actors Filter · accounts_dm Filter accounts_dm idle · 2 actors StreamScan · accounts_dm StreamScan accounts_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 63825 (Actor 746320,746319)
StreamMaterialize { columns: [account_id, account_name, account_number, account_type, base_currency_code, opening_date, created_at, is_restricted, product_id, product_type, product_name_en, product_name_ar, status_label_id, status_name_en, status_name_ar, status_color, system_status, currency_code, currency_name_en, currency_name_ar, currency_symbol, owners, owner_count, portfolios, portfolio_count, task_active_count, task_high_priority_count, market_value, fair_value, market_value_system_currency, fair_value_system_currency, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, maturity_date, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, last_4_digits, financing_limit, outstanding_balance, reference_identifiers, $expr1(hidden), accounts_dm.product_type_id(hidden), position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded(hidden), position_snapshot_mv_next.flag(hidden), account_latest_facts_mv.$src(hidden)], stream_key: [account_id, $expr1, currency_code, status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src], pk_columns: [account_id, $expr1, currency_code, status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src], pk_conflict: NoCheck }
├── output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, $expr2, accounts_dm.base_currency_code, accounts_dm.opening_date, accounts_dm.created_at, $expr3, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, accounts_dm.status_label_id, labels_dm.name_en, labels_dm.name_ar, labels_dm.color, $expr4, accounts_dm.base_currency_code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, $expr15, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, credit_card_accounts_dm.last_4_digits, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, $expr16, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ]
├── stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ]
└── StreamProject
└─exprs:
  ┌─accounts_dm.account_id
  ├─accounts_dm.name
  ├─accounts_dm.number
  ├─Coalesce(product_types_dm.type, 'UNKNOWN':Varchar) as $expr2
  ├─accounts_dm.base_currency_code
  ├─accounts_dm.opening_date
  ├─accounts_dm.created_at
  ├─Coalesce(accounts_dm.is_restricted, false:Boolean) as $expr3
  ├─product_types_dm.product_type_id
  ├─product_types_dm.type
  ├─product_types_dm.name_en
  ├─product_types_dm.name_ar
  ├─accounts_dm.status_label_id
  ├─labels_dm.name_en
  ├─labels_dm.name_ar
  ├─labels_dm.color
  ├─Coalesce(accounts_dm.system_status, 'ACTIVE':Varchar) as $expr4
  ├─accounts_dm.base_currency_code
  ├─currencies_dm.name_en
  ├─currencies_dm.name_ar
  ├─currencies_dm.symbol
  ├─Coalesce(account_owners_mv.owners, '[]':Jsonb) as $expr5
  ├─Coalesce(account_owners_mv.owner_count, 0:Int32) as $expr6
  ├─Coalesce(account_portfolios_mv.portfolios, '[]':Jsonb) as $expr7
  ├─Coalesce(account_portfolios_mv.portfolio_count, 0:Int32) as $expr8
  ├─Coalesce(account_task_counts_mv.active_count, 0:Int32) as $expr9
  ├─Coalesce(account_task_counts_mv.high_priority_count, 0:Int32) as $expr10
  ├─Coalesce(position_snapshot_mv_next.market_value, 0:Decimal) as $expr11
  ├─Coalesce(position_snapshot_mv_next.fair_value, 0:Decimal) as $expr12
  ├─Coalesce(position_snapshot_mv_next.market_value_system_currency, 0:Decimal) as $expr13
  ├─Coalesce(position_snapshot_mv_next.fair_value_system_currency, 0:Decimal) as $expr14
  ├─account_latest_facts_mv.available_balance
  ├─account_latest_facts_mv.hold_balance
  ├─account_latest_facts_mv.purchasing_power
  ├─account_latest_facts_mv.profit_rate
  ├─account_latest_facts_mv.profit_accrued
  ├─account_latest_facts_mv.principal
  ├─Coalesce(fixed_deposit_accounts_dm.maturity_date, financing_accounts_dm.maturity_date, structured_deposit_accounts_dm.maturity_date) as $expr15
  ├─account_latest_facts_mv.auto_renewal_status
  ├─account_latest_facts_mv.credit_limit
  ├─account_latest_facts_mv.last_statement_balance
  ├─account_latest_facts_mv.minimum_payment_due
  ├─account_latest_facts_mv.payment_due_date
  ├─credit_card_accounts_dm.last_4_digits
  ├─account_latest_facts_mv.financing_limit
  ├─account_latest_facts_mv.outstanding_balance
  ├─Coalesce(account_reference_identifiers_mv.reference_identifiers, '[]':Jsonb) as $expr16
  ├─$expr1
  ├─accounts_dm.product_type_id
  ├─position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded
  ├─position_snapshot_mv_next.flag
  └─account_latest_facts_mv.$src
    ├── output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, $expr2, accounts_dm.base_currency_code, accounts_dm.opening_date, accounts_dm.created_at, $expr3, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, accounts_dm.status_label_id, labels_dm.name_en, labels_dm.name_ar, labels_dm.color, $expr4, accounts_dm.base_currency_code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, $expr15, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, credit_card_accounts_dm.last_4_digits, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, $expr16, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ]
    ├── stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ]
    └── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, structured_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, structured_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 63826 (Actor 746318,746317)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, structured_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, structured_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = structured_deposit_accounts_dm.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, structured_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, structured_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, fixed_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    └── MergeExecutor { output: [ structured_deposit_accounts_dm.account_id, structured_deposit_accounts_dm.maturity_date ], stream key: [ structured_deposit_accounts_dm.account_id ] }

Fragment 63827 (Actor 746323,746324)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, fixed_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, fixed_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 63828 (Actor 746321,746322)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, fixed_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = fixed_deposit_accounts_dm.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, fixed_deposit_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, fixed_deposit_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, financing_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    └── MergeExecutor { output: [ fixed_deposit_accounts_dm.account_id, fixed_deposit_accounts_dm.maturity_date ], stream key: [ fixed_deposit_accounts_dm.account_id ] }

Fragment 63829 (Actor 746327,746328)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, financing_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, financing_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 63830 (Actor 746325,746326)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, financing_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = financing_accounts_dm.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, financing_accounts_dm.maturity_date, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, financing_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, credit_card_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    └── MergeExecutor { output: [ financing_accounts_dm.account_id, financing_accounts_dm.maturity_date ], stream key: [ financing_accounts_dm.account_id ] }

Fragment 63831 (Actor 746330,746329)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, credit_card_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, credit_card_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 63832 (Actor 746332,746331)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, credit_card_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = credit_card_accounts_dm.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, credit_card_accounts_dm.last_4_digits, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src, credit_card_accounts_dm.account_id ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.account_id, account_latest_facts_mv.$src ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    └── MergeExecutor { output: [ credit_card_accounts_dm.account_id, credit_card_accounts_dm.last_4_digits ], stream key: [ credit_card_accounts_dm.account_id ] }

Fragment 63833 (Actor 746334,746333)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.account_id, account_latest_facts_mv.$src ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.account_id, account_latest_facts_mv.$src ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 63834 (Actor 746336,746335)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.account_id, account_latest_facts_mv.$src ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = account_latest_facts_mv.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.account_id, account_latest_facts_mv.$src ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
    └── MergeExecutor { output: [ account_latest_facts_mv.account_id, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, account_latest_facts_mv.$src ], stream key: [ account_latest_facts_mv.account_id, account_latest_facts_mv.$src ] }

Fragment 63835 (Actor 746338,746337)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ accounts_dm.account_id, $expr1, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ $expr1, accounts_dm.base_currency_code, accounts_dm.account_id, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 63836 (Actor 746339,746340)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ $expr1, accounts_dm.base_currency_code, accounts_dm.account_id, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr1 = position_snapshot_mv_next.account_group_id AND accounts_dm.base_currency_code = position_snapshot_mv_next.currency_code } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ $expr1, accounts_dm.base_currency_code, accounts_dm.account_id, accounts_dm.status_label_id, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, $expr1, accounts_dm.product_type_id ], stream key: [ $expr1, accounts_dm.base_currency_code, accounts_dm.account_id, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    └── MergeExecutor { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 63837 (Actor 744049,744050)
StreamLocalityProvider { locality_columns: [$expr1, accounts_dm.base_currency_code] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, $expr1, accounts_dm.product_type_id ], stream key: [ $expr1, accounts_dm.base_currency_code, accounts_dm.account_id, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, $expr1, accounts_dm.product_type_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }

Fragment 63838 (Actor 744066,744065)
StreamProject { exprs: [accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, ConcatOp('account_group_':Varchar, Md5(ConcatOp(accounts_dm.account_id, 'all':Varchar)::Bytea)) as $expr1, accounts_dm.product_type_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, $expr1, accounts_dm.product_type_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, accounts_dm.product_type_id, account_reference_identifiers_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }

Fragment 63839 (Actor 744064,744063)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, accounts_dm.product_type_id, account_reference_identifiers_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = account_reference_identifiers_mv.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, account_reference_identifiers_mv.reference_identifiers, accounts_dm.product_type_id, account_reference_identifiers_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, accounts_dm.product_type_id, account_task_counts_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    └── MergeExecutor { output: [ account_reference_identifiers_mv.account_id, account_reference_identifiers_mv.reference_identifiers ], stream key: [ account_reference_identifiers_mv.account_id ] }

Fragment 63840 (Actor 744093,744094)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, accounts_dm.product_type_id, account_task_counts_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, accounts_dm.product_type_id, account_task_counts_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }

Fragment 63841 (Actor 744092,744091)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, accounts_dm.product_type_id, account_task_counts_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = account_task_counts_mv.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count, accounts_dm.product_type_id, account_task_counts_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, accounts_dm.product_type_id, account_portfolios_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    └── MergeExecutor { output: [ account_task_counts_mv.account_id, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count ], stream key: [ account_task_counts_mv.account_id ] }

Fragment 63842 (Actor 746820,746819)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, accounts_dm.product_type_id, account_portfolios_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, accounts_dm.product_type_id, account_portfolios_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }

Fragment 63843 (Actor 746818,746817)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, accounts_dm.product_type_id, account_portfolios_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = account_portfolios_mv.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count, accounts_dm.product_type_id, account_portfolios_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, accounts_dm.product_type_id, account_owners_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    └── MergeExecutor { output: [ account_portfolios_mv.account_id, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count ], stream key: [ account_portfolios_mv.account_id ] }

Fragment 63844 (Actor 746821,746822)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, accounts_dm.product_type_id, account_owners_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, accounts_dm.product_type_id, account_owners_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }

Fragment 63845 (Actor 746824,746823)
StreamSyncLogStore { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, accounts_dm.product_type_id, account_owners_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm.account_id = account_owners_mv.account_id } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, account_owners_mv.owners, account_owners_mv.owner_count, accounts_dm.product_type_id, account_owners_mv.account_id ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    ├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, accounts_dm.product_type_id, currencies_dm.code ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
    └── MergeExecutor { output: [ account_owners_mv.account_id, account_owners_mv.owners, account_owners_mv.owner_count ], stream key: [ account_owners_mv.account_id ] }

Fragment 63846 (Actor 746826,746825)
StreamLocalityProvider { locality_columns: [accounts_dm.account_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, accounts_dm.product_type_id, currencies_dm.code ], stream key: [ accounts_dm.account_id, accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, accounts_dm.product_type_id, currencies_dm.code ], stream key: [ accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }

Fragment 63847 (Actor 741744,741743)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: accounts_dm.base_currency_code = currencies_dm.code, nested_loop: false } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, accounts_dm.product_type_id, currencies_dm.code ], stream key: [ accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }
├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, accounts_dm.product_type_id, labels_dm.label_id ], stream key: [ accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }
└── MergeExecutor { output: [ currencies_dm.code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol ], stream key: [ currencies_dm.code ] }

Fragment 63848 (Actor 744176,744175)
StreamLocalityProvider { locality_columns: [accounts_dm.base_currency_code] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, accounts_dm.product_type_id, labels_dm.label_id ], stream key: [ accounts_dm.base_currency_code, accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, accounts_dm.product_type_id, labels_dm.label_id ], stream key: [ accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }

Fragment 63849 (Actor 742303,742304)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: accounts_dm.status_label_id = labels_dm.label_id, nested_loop: false } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, accounts_dm.product_type_id, labels_dm.label_id ], stream key: [ accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }
├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, accounts_dm.product_type_id ], stream key: [ accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }
└── MergeExecutor { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ labels_dm.label_id ] }

Fragment 63850 (Actor 744285,744286)
StreamLocalityProvider { locality_columns: [accounts_dm.status_label_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, accounts_dm.product_type_id ], stream key: [ accounts_dm.status_label_id, accounts_dm.product_type_id, accounts_dm.account_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, accounts_dm.product_type_id ], stream key: [ accounts_dm.product_type_id, accounts_dm.account_id ] }

Fragment 63851 (Actor 742339,742338)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: accounts_dm.product_type_id = product_types_dm.product_type_id, nested_loop: false } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar, accounts_dm.product_type_id ], stream key: [ accounts_dm.product_type_id, accounts_dm.account_id ] }
├── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.product_type_id, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status ], stream key: [ accounts_dm.product_type_id, accounts_dm.account_id ] }
└── MergeExecutor { output: [ product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar ], stream key: [ product_types_dm.product_type_id ] }

Fragment 63852 (Actor 746827,746828)
StreamLocalityProvider { locality_columns: [accounts_dm.product_type_id] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.product_type_id, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status ], stream key: [ accounts_dm.product_type_id, accounts_dm.account_id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.product_type_id, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status ], stream key: [ accounts_dm.account_id ] }

Fragment 63853 (Actor 746829,746830)
StreamProject { exprs: [accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.product_type_id, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.product_type_id, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status ], stream key: [ accounts_dm.account_id ] }
└── StreamFilter { predicate: IsNull(accounts_dm.closing_date) AND IsNull(accounts_dm.disabled_at) } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.product_type_id, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, accounts_dm.closing_date, accounts_dm.disabled_at ], stream key: [ accounts_dm.account_id ] }
    └── StreamTableScan { table: accounts_dm, columns: [account_id, name, number, product_type_id, base_currency_code, is_restricted, opening_date, created_at, status_label_id, system_status, closing_date, disabled_at] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number, accounts_dm.product_type_id, accounts_dm.base_currency_code, accounts_dm.is_restricted, accounts_dm.opening_date, accounts_dm.created_at, accounts_dm.status_label_id, accounts_dm.system_status, accounts_dm.closing_date, accounts_dm.disabled_at ], stream key: [ accounts_dm.account_id ] }
        ├── Upstream { output: [ account_id, name, number, product_type_id, base_currency_code, is_restricted, opening_date, created_at, status_label_id, system_status, closing_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, name, number, product_type_id, base_currency_code, is_restricted, opening_date, created_at, status_label_id, system_status, closing_date, disabled_at ], stream key: [] }

Fragment 63854 (Actor 742332,742333)
StreamTableScan { table: product_types_dm, columns: [product_type_id, type, name_en, name_ar] } { output: [ product_types_dm.product_type_id, product_types_dm.type, product_types_dm.name_en, product_types_dm.name_ar ], stream key: [ product_types_dm.product_type_id ] }
├── Upstream { output: [ product_type_id, type, name_en, name_ar ], stream key: [] }
└── BatchPlanNode { output: [ product_type_id, type, name_en, name_ar ], stream key: [] }

Fragment 63855 (Actor 742290,742289)
StreamTableScan { table: labels_dm, columns: [label_id, name_ar, name_en, color] } { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ labels_dm.label_id ] }
├── Upstream { output: [ label_id, name_ar, name_en, color ], stream key: [] }
└── BatchPlanNode { output: [ label_id, name_ar, name_en, color ], stream key: [] }

Fragment 63856 (Actor 741745,741746)
StreamTableScan { table: currencies_dm, columns: [code, name_en, name_ar, symbol] } { output: [ currencies_dm.code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol ], stream key: [ currencies_dm.code ] }
├── Upstream { output: [ code, name_en, name_ar, symbol ], stream key: [] }
└── BatchPlanNode { output: [ code, name_en, name_ar, symbol ], stream key: [] }

Fragment 63857 (Actor 746832,746831)
StreamTableScan { table: account_owners_mv, columns: [account_id, owners, owner_count] } { output: [ account_owners_mv.account_id, account_owners_mv.owners, account_owners_mv.owner_count ], stream key: [ account_owners_mv.account_id ] }
├── Upstream { output: [ account_id, owners, owner_count ], stream key: [] }
└── BatchPlanNode { output: [ account_id, owners, owner_count ], stream key: [] }

Fragment 63858 (Actor 746834,746833)
StreamTableScan { table: account_portfolios_mv, columns: [account_id, portfolios, portfolio_count] } { output: [ account_portfolios_mv.account_id, account_portfolios_mv.portfolios, account_portfolios_mv.portfolio_count ], stream key: [ account_portfolios_mv.account_id ] }
├── Upstream { output: [ account_id, portfolios, portfolio_count ], stream key: [] }
└── BatchPlanNode { output: [ account_id, portfolios, portfolio_count ], stream key: [] }

Fragment 63859 (Actor 746836,746835)
StreamTableScan { table: account_task_counts_mv, columns: [account_id, active_count, high_priority_count] } { output: [ account_task_counts_mv.account_id, account_task_counts_mv.active_count, account_task_counts_mv.high_priority_count ], stream key: [ account_task_counts_mv.account_id ] }
├── Upstream { output: [ account_id, active_count, high_priority_count ], stream key: [] }
└── BatchPlanNode { output: [ account_id, active_count, high_priority_count ], stream key: [] }

Fragment 63860 (Actor 746837,746838)
StreamTableScan { table: account_reference_identifiers_mv, columns: [account_id, reference_identifiers] } { output: [ account_reference_identifiers_mv.account_id, account_reference_identifiers_mv.reference_identifiers ], stream key: [ account_reference_identifiers_mv.account_id ] }
├── Upstream { output: [ account_id, reference_identifiers ], stream key: [] }
└── BatchPlanNode { output: [ account_id, reference_identifiers ], stream key: [] }

Fragment 63861 (Actor 746839,746840)
StreamLocalityProvider { locality_columns: [position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 63862 (Actor 746842,746841)
StreamProject { exprs: [position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamFilter { predicate: (position_snapshot_mv_next.position_type = 'POSITION':Varchar) } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
    └── StreamTableScan { table: position_snapshot_mv_next, columns: [account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
        ├── Upstream { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }
        └── BatchPlanNode { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }

Fragment 63863 (Actor 744448,744447)
StreamLocalityProvider { locality_columns: [account_latest_facts_mv.account_id] } { output: [ account_latest_facts_mv.account_id, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, account_latest_facts_mv.$src ], stream key: [ account_latest_facts_mv.account_id, account_latest_facts_mv.$src ] }
└── MergeExecutor { output: [ account_latest_facts_mv.account_id, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, account_latest_facts_mv.$src ], stream key: [ account_latest_facts_mv.account_id, account_latest_facts_mv.$src ] }

Fragment 63864 (Actor 744449,744450)
StreamTableScan { table: account_latest_facts_mv, columns: [account_id, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, financing_limit, outstanding_balance, $src] } { output: [ account_latest_facts_mv.account_id, account_latest_facts_mv.available_balance, account_latest_facts_mv.hold_balance, account_latest_facts_mv.purchasing_power, account_latest_facts_mv.profit_rate, account_latest_facts_mv.profit_accrued, account_latest_facts_mv.principal, account_latest_facts_mv.auto_renewal_status, account_latest_facts_mv.credit_limit, account_latest_facts_mv.last_statement_balance, account_latest_facts_mv.minimum_payment_due, account_latest_facts_mv.payment_due_date, account_latest_facts_mv.financing_limit, account_latest_facts_mv.outstanding_balance, account_latest_facts_mv.$src ], stream key: [ account_latest_facts_mv.account_id, account_latest_facts_mv.$src ] }
├── Upstream { output: [ account_id, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, financing_limit, outstanding_balance, $src ], stream key: [] }
└── BatchPlanNode { output: [ account_id, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, financing_limit, outstanding_balance, $src ], stream key: [] }

Fragment 63865 (Actor 744457,744458)
StreamProject { exprs: [credit_card_accounts_dm.account_id, credit_card_accounts_dm.last_4_digits] } { output: [ credit_card_accounts_dm.account_id, credit_card_accounts_dm.last_4_digits ], stream key: [ credit_card_accounts_dm.account_id ] }
└── StreamFilter { predicate: IsNull(credit_card_accounts_dm.disabled_at) } { output: [ credit_card_accounts_dm.account_id, credit_card_accounts_dm.last_4_digits, credit_card_accounts_dm.disabled_at ], stream key: [ credit_card_accounts_dm.account_id ] }
    └── StreamTableScan { table: credit_card_accounts_dm, columns: [account_id, last_4_digits, disabled_at] } { output: [ credit_card_accounts_dm.account_id, credit_card_accounts_dm.last_4_digits, credit_card_accounts_dm.disabled_at ], stream key: [ credit_card_accounts_dm.account_id ] }
        ├── Upstream { output: [ account_id, last_4_digits, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, last_4_digits, disabled_at ], stream key: [] }

Fragment 63866 (Actor 744461,744462)
StreamProject { exprs: [financing_accounts_dm.account_id, financing_accounts_dm.maturity_date] } { output: [ financing_accounts_dm.account_id, financing_accounts_dm.maturity_date ], stream key: [ financing_accounts_dm.account_id ] }
└── StreamFilter { predicate: IsNull(financing_accounts_dm.disabled_at) } { output: [ financing_accounts_dm.account_id, financing_accounts_dm.maturity_date, financing_accounts_dm.disabled_at ], stream key: [ financing_accounts_dm.account_id ] }
    └── StreamTableScan { table: financing_accounts_dm, columns: [account_id, maturity_date, disabled_at] } { output: [ financing_accounts_dm.account_id, financing_accounts_dm.maturity_date, financing_accounts_dm.disabled_at ], stream key: [ financing_accounts_dm.account_id ] }
        ├── Upstream { output: [ account_id, maturity_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, maturity_date, disabled_at ], stream key: [] }

Fragment 63867 (Actor 744463,744464)
StreamProject { exprs: [fixed_deposit_accounts_dm.account_id, fixed_deposit_accounts_dm.maturity_date] } { output: [ fixed_deposit_accounts_dm.account_id, fixed_deposit_accounts_dm.maturity_date ], stream key: [ fixed_deposit_accounts_dm.account_id ] }
└── StreamFilter { predicate: IsNull(fixed_deposit_accounts_dm.disabled_at) } { output: [ fixed_deposit_accounts_dm.account_id, fixed_deposit_accounts_dm.maturity_date, fixed_deposit_accounts_dm.disabled_at ], stream key: [ fixed_deposit_accounts_dm.account_id ] }
    └── StreamTableScan { table: fixed_deposit_accounts_dm, columns: [account_id, maturity_date, disabled_at] } { output: [ fixed_deposit_accounts_dm.account_id, fixed_deposit_accounts_dm.maturity_date, fixed_deposit_accounts_dm.disabled_at ], stream key: [ fixed_deposit_accounts_dm.account_id ] }
        ├── Upstream { output: [ account_id, maturity_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, maturity_date, disabled_at ], stream key: [] }

Fragment 63868 (Actor 744560,744561)
StreamProject { exprs: [structured_deposit_accounts_dm.account_id, structured_deposit_accounts_dm.maturity_date] } { output: [ structured_deposit_accounts_dm.account_id, structured_deposit_accounts_dm.maturity_date ], stream key: [ structured_deposit_accounts_dm.account_id ] }
└── StreamFilter { predicate: IsNull(structured_deposit_accounts_dm.disabled_at) } { output: [ structured_deposit_accounts_dm.account_id, structured_deposit_accounts_dm.maturity_date, structured_deposit_accounts_dm.disabled_at ], stream key: [ structured_deposit_accounts_dm.account_id ] }
    └── StreamTableScan { table: structured_deposit_accounts_dm, columns: [account_id, maturity_date, disabled_at] } { output: [ structured_deposit_accounts_dm.account_id, structured_deposit_accounts_dm.maturity_date, structured_deposit_accounts_dm.disabled_at ], stream key: [ structured_deposit_accounts_dm.account_id ] }
        ├── Upstream { output: [ account_id, maturity_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, maturity_date, disabled_at ], stream key: [] }