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 61376 (Actor 738248,738247)
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.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.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.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.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.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.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.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.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.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.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 61377 (Actor 738246,738245)
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.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.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.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.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.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.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 61378 (Actor 738250,738249)
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.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.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.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.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 61379 (Actor 738251,738252)
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.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.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.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.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.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.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 61380 (Actor 738256,738255)
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.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.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.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.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 61381 (Actor 738254,738253)
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.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.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.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.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.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.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 61382 (Actor 738260,738259)
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.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.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.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.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 61383 (Actor 738258,738257)
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.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.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.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.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.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.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 61384 (Actor 738264,738263)
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.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.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.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.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ] }

Fragment 61385 (Actor 738261,738262)
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.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.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.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.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.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.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 61386 (Actor 738266,738265)
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.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.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.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.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 61387 (Actor 738268,738267)
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.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.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.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.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.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.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 61388 (Actor 738929,738930)
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 61389 (Actor 738933,738934)
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 61390 (Actor 738932,738931)
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 61391 (Actor 738935,738936)
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 61392 (Actor 738938,738937)
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 61393 (Actor 738942,738941)
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 61394 (Actor 738940,738939)
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 61395 (Actor 738943,738944)
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 61396 (Actor 738946,738945)
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 61397 (Actor 738947,738948)
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 61398 (Actor 740049,740050)
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 61399 (Actor 738949,738950)
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 61400 (Actor 737564,737565)
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 61401 (Actor 738951,738952)
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 61402 (Actor 736173,736174)
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 61403 (Actor 738954,738953)
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 61404 (Actor 738955,738956)
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 61405 (Actor 736180,736179)
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 61406 (Actor 737587,737586)
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 61407 (Actor 740035,740036)
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 61408 (Actor 738958,738957)
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 61409 (Actor 738960,738959)
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 61410 (Actor 738961,738962)
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 61411 (Actor 738964,738963)
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 61412 (Actor 738965,738966)
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.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.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.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.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 61413 (Actor 738967,738968)
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.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.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.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.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.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.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.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.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.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.type_expanded, flag, position_type ], stream key: [] }

Fragment 61414 (Actor 738969,738970)
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 61415 (Actor 738972,738971)
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 61416 (Actor 738973,738974)
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 61417 (Actor 738976,738975)
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 61418 (Actor 738977,738978)
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 61419 (Actor 738980,738979)
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: [] }