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

← cluster alinma_bff objects book_of_business_clients_mv explain
Overview Objects Graph History
materialized view · alinma_bff.book_of_business_clients_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
143 operators
Materialize · alinma_bff.book_of_business_clients_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · clients_dm.id = client_fee_totals_mv_next.client_id AND cli…
— — 2 actors
HashJoin · LeftOuter · clients_dm.id = client_fee_totals_mv_next.client_id AND cli… 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 · client_fee_totals_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
SyncLogStore · LeftOuter · clients_dm.id = client_aum_mv_next.client_id AND client_to_…
— — 2 actors
HashJoin · LeftOuter · clients_dm.id = client_aum_mv_next.client_id AND client_to_… 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 · client_aum_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
SyncLogStore · LeftOuter · client_to_account_groups_mv.account_group_id = position_sna…
— — 2 actors
HashJoin · LeftOuter · client_to_account_groups_mv.account_group_id = position_sna… 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
SyncLogStore · LeftOuter · clients_dm.id = client_reference_identifiers_mv.client_id
— — 2 actors
HashJoin · LeftOuter · clients_dm.id = client_reference_identifiers_mv.client_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 · client_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 · clients_dm.id = client_task_counts_mv.client_id
— — 2 actors
HashJoin · LeftOuter · clients_dm.id = client_task_counts_mv.client_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 · client_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 · clients_dm.id = client_contact_counts_mv.client_id
— — 2 actors
HashJoin · LeftOuter · clients_dm.id = client_contact_counts_mv.client_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 · client_contact_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 · clients_dm.id = client_portfolio_counts_mv.client_id
— — 2 actors
HashJoin · LeftOuter · clients_dm.id = client_portfolio_counts_mv.client_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 · client_portfolio_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
TemporalJoin · LeftOuter · clients_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 · clients_dm.status_label_id = labels_dm.label_id, nested_loo…
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 · clients_dm.segment_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
SyncLogStore · Inner · clients_dm.id = client_to_account_groups_mv.client_id
— — 2 actors
HashJoin · Inner · clients_dm.id = client_to_account_groups_mv.client_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 · client_to_account_groups_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · clients_dm
— — 2 actors
Filter · clients_dm
0% idle 2 actors
StreamScan · clients_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_clients_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 · clients_dm.id = client_fee_totals_mv_next.client_id AND cli… SyncLogStore LeftOuter · clients_dm.… — · 2 actors HashJoin · LeftOuter · clients_dm.id = client_fee_totals_mv_next.client_id AND cli… HashJoin LeftOuter · clients_dm.… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · client_fee_totals_mv_next StreamScan client_fee_totals_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 SyncLogStore · LeftOuter · clients_dm.id = client_aum_mv_next.client_id AND client_to_… SyncLogStore LeftOuter · clients_dm.… — · 2 actors HashJoin · LeftOuter · clients_dm.id = client_aum_mv_next.client_id AND client_to_… HashJoin LeftOuter · clients_dm.… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · client_aum_mv_next StreamScan client_aum_mv_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · client_to_account_groups_mv.account_group_id = position_sna… SyncLogStore LeftOuter · client_to_a… — · 2 actors HashJoin · LeftOuter · client_to_account_groups_mv.account_group_id = position_sna… HashJoin LeftOuter · client_to_a… 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 SyncLogStore · LeftOuter · clients_dm.id = client_reference_identifiers_mv.client_id SyncLogStore LeftOuter · clients_dm.… — · 2 actors HashJoin · LeftOuter · clients_dm.id = client_reference_identifiers_mv.client_id HashJoin LeftOuter · clients_dm.… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · client_reference_identifiers_mv StreamScan client_reference_identi… 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 · clients_dm.id = client_task_counts_mv.client_id SyncLogStore LeftOuter · clients_dm.… — · 2 actors HashJoin · LeftOuter · clients_dm.id = client_task_counts_mv.client_id HashJoin LeftOuter · clients_dm.… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · client_task_counts_mv StreamScan client_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 · clients_dm.id = client_contact_counts_mv.client_id SyncLogStore LeftOuter · clients_dm.… — · 2 actors HashJoin · LeftOuter · clients_dm.id = client_contact_counts_mv.client_id HashJoin LeftOuter · clients_dm.… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · client_contact_counts_mv StreamScan client_contact_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 · clients_dm.id = client_portfolio_counts_mv.client_id SyncLogStore LeftOuter · clients_dm.… — · 2 actors HashJoin · LeftOuter · clients_dm.id = client_portfolio_counts_mv.client_id HashJoin LeftOuter · clients_dm.… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · client_portfolio_counts_mv StreamScan client_portfolio_counts… 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 · clients_dm.base_currency_code = currencies_dm.code, nested_… TemporalJoin LeftOuter · clients_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 · clients_dm.status_label_id = labels_dm.label_id, nested_loo… TemporalJoin LeftOuter · clients_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 · clients_dm.segment_label_id = labels_dm.label_id, nested_lo… TemporalJoin LeftOuter · clients_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 SyncLogStore · Inner · clients_dm.id = client_to_account_groups_mv.client_id SyncLogStore Inner · clients_dm.id =… — · 2 actors HashJoin · Inner · clients_dm.id = client_to_account_groups_mv.client_id HashJoin Inner · clients_dm.id =… 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 · client_to_account_groups_mv StreamScan client_to_account_group… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · clients_dm Project clients_dm — · 2 actors Filter · clients_dm Filter clients_dm idle · 2 actors StreamScan · clients_dm StreamScan clients_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 61653 (Actor 739509,739510)
StreamMaterialize { columns: [client_id, client_type, base_currency_code, created_at, onboarding_date, next_kyc_review_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, segment_name_en, segment_name_ar, segment_color, status_label_id, status_name_en, status_name_ar, status_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, market_value, fair_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, aum_value, fair_aum_value, aum_value_system_currency, fair_aum_value_system_currency, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency, reference_identifiers, client_to_account_groups_mv.account_group_id(hidden), client_to_account_groups_mv.$src(hidden), position_snapshot_mv_next.holding_values_latest_mv.type_expanded(hidden), position_snapshot_mv_next.flag(hidden)], stream_key: [client_id, account_group_type, client_to_account_groups_mv.account_group_id, currency_code, status_label_id, segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag], pk_columns: [client_id, account_group_type, client_to_account_groups_mv.account_group_id, currency_code, status_label_id, segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag], pk_conflict: NoCheck }
├── output: [ clients_dm.id, clients_dm.type, clients_dm.base_currency_code, clients_dm.created_at, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, client_to_account_groups_mv.type, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.customer_identification_file, clients_dm.segment_label_id, labels_dm.name_en, labels_dm.name_ar, labels_dm.color, clients_dm.status_label_id, labels_dm.name_en, labels_dm.name_ar, labels_dm.color, clients_dm.base_currency_code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr1, $expr2, $expr3, $expr4, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, $expr15, $expr16, $expr17, $expr18, $expr19, $expr20, $expr21, $expr22, $expr23, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ]
├── stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ]
└── StreamProject
└─exprs:
  ┌─clients_dm.id
  ├─clients_dm.type
  ├─clients_dm.base_currency_code
  ├─clients_dm.created_at
  ├─clients_dm.onboarding_date
  ├─clients_dm.next_kyc_review_date
  ├─client_to_account_groups_mv.type
  ├─clients_dm.display_name
  ├─clients_dm.local_display_name
  ├─clients_dm.preferred_name
  ├─clients_dm.prefix
  ├─clients_dm.suffix
  ├─clients_dm.first_name
  ├─clients_dm.last_name
  ├─clients_dm.customer_identification_file
  ├─clients_dm.segment_label_id
  ├─labels_dm.name_en
  ├─labels_dm.name_ar
  ├─labels_dm.color
  ├─clients_dm.status_label_id
  ├─labels_dm.name_en
  ├─labels_dm.name_ar
  ├─labels_dm.color
  ├─clients_dm.base_currency_code
  ├─currencies_dm.name_en
  ├─currencies_dm.name_ar
  ├─currencies_dm.symbol
  ├─Coalesce(client_portfolio_counts_mv.portfolio_count, 0:Int32) as $expr1
  ├─Coalesce(client_contact_counts_mv.contact_count, 0:Int32) as $expr2
  ├─Coalesce(client_task_counts_mv.active_count, 0:Int32) as $expr3
  ├─Coalesce(client_task_counts_mv.high_priority_count, 0:Int32) as $expr4
  ├─Coalesce(position_snapshot_mv_next.market_value, 0:Decimal) as $expr5
  ├─Coalesce(position_snapshot_mv_next.fair_value, 0:Decimal) as $expr6
  ├─Coalesce(position_snapshot_mv_next.relationship_value, 0:Decimal) as $expr7
  ├─Coalesce(position_snapshot_mv_next.fair_relationship_value, 0:Decimal) as $expr8
  ├─Coalesce(position_snapshot_mv_next.market_value_system_currency, 0:Decimal) as $expr9
  ├─Coalesce(position_snapshot_mv_next.fair_value_system_currency, 0:Decimal) as $expr10
  ├─Coalesce(position_snapshot_mv_next.relationship_value_system_currency, 0:Decimal) as $expr11
  ├─Coalesce(position_snapshot_mv_next.fair_relationship_value_system_currency, 0:Decimal) as $expr12
  ├─Coalesce(client_aum_mv_next.aum_market_value, 0:Decimal) as $expr13
  ├─Coalesce(client_aum_mv_next.fair_aum_market_value, 0:Decimal) as $expr14
  ├─Coalesce(client_aum_mv_next.aum_market_value_system_currency, 0:Decimal) as $expr15
  ├─Coalesce(client_aum_mv_next.fair_aum_market_value_system_currency, 0:Decimal) as $expr16
  ├─Coalesce(client_fee_totals_mv_next.total_fees, 0:Decimal) as $expr17
  ├─Coalesce(client_fee_totals_mv_next.transactional_fees, 0:Decimal) as $expr18
  ├─Coalesce(client_fee_totals_mv_next.non_transactional_fees, 0:Decimal) as $expr19
  ├─Coalesce(client_fee_totals_mv_next.total_fees_system_currency, 0:Decimal) as $expr20
  ├─Coalesce(client_fee_totals_mv_next.transactional_fees_system_currency, 0:Decimal) as $expr21
  ├─Coalesce(client_fee_totals_mv_next.non_transactional_fees_system_currency, 0:Decimal) as $expr22
  ├─Coalesce(client_reference_identifiers_mv.reference_identifiers, '[]':Jsonb) as $expr23
  ├─client_to_account_groups_mv.account_group_id
  ├─client_to_account_groups_mv.$src
  ├─position_snapshot_mv_next.holding_values_latest_mv.type_expanded
  └─position_snapshot_mv_next.flag
    ├── output: [ clients_dm.id, clients_dm.type, clients_dm.base_currency_code, clients_dm.created_at, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, client_to_account_groups_mv.type, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.customer_identification_file, clients_dm.segment_label_id, labels_dm.name_en, labels_dm.name_ar, labels_dm.color, clients_dm.status_label_id, labels_dm.name_en, labels_dm.name_ar, labels_dm.color, clients_dm.base_currency_code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr1, $expr2, $expr3, $expr4, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, $expr15, $expr16, $expr17, $expr18, $expr19, $expr20, $expr21, $expr22, $expr23, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ]
    ├── stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ]
    └── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_fee_totals_mv_next.total_fees, client_fee_totals_mv_next.transactional_fees, client_fee_totals_mv_next.non_transactional_fees, client_fee_totals_mv_next.total_fees_system_currency, client_fee_totals_mv_next.transactional_fees_system_currency, client_fee_totals_mv_next.non_transactional_fees_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_fee_totals_mv_next.client_id, client_fee_totals_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 61654 (Actor 739507,739508)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_fee_totals_mv_next.total_fees, client_fee_totals_mv_next.transactional_fees, client_fee_totals_mv_next.non_transactional_fees, client_fee_totals_mv_next.total_fees_system_currency, client_fee_totals_mv_next.transactional_fees_system_currency, client_fee_totals_mv_next.non_transactional_fees_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_fee_totals_mv_next.client_id, client_fee_totals_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_fee_totals_mv_next.client_id AND client_to_account_groups_mv.type = client_fee_totals_mv_next.account_group_type } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_fee_totals_mv_next.total_fees, client_fee_totals_mv_next.transactional_fees, client_fee_totals_mv_next.non_transactional_fees, client_fee_totals_mv_next.total_fees_system_currency, client_fee_totals_mv_next.transactional_fees_system_currency, client_fee_totals_mv_next.non_transactional_fees_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_fee_totals_mv_next.client_id, client_fee_totals_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_aum_mv_next.client_id, client_aum_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
    └── MergeExecutor { output: [ client_fee_totals_mv_next.client_id, client_fee_totals_mv_next.account_group_type, client_fee_totals_mv_next.total_fees, client_fee_totals_mv_next.transactional_fees, client_fee_totals_mv_next.non_transactional_fees, client_fee_totals_mv_next.total_fees_system_currency, client_fee_totals_mv_next.transactional_fees_system_currency, client_fee_totals_mv_next.non_transactional_fees_system_currency ], stream key: [ client_fee_totals_mv_next.client_id, client_fee_totals_mv_next.account_group_type ] }

Fragment 61655 (Actor 739513,739514)
StreamLocalityProvider { locality_columns: [clients_dm.id, client_to_account_groups_mv.type] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_aum_mv_next.client_id, client_aum_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_aum_mv_next.client_id, client_aum_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 61656 (Actor 739512,739511)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_aum_mv_next.client_id, client_aum_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_aum_mv_next.client_id AND client_to_account_groups_mv.type = client_aum_mv_next.account_group_type } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, client_aum_mv_next.client_id, client_aum_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, 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: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
    └── MergeExecutor { output: [ client_aum_mv_next.client_id, client_aum_mv_next.account_group_type, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency ], stream key: [ client_aum_mv_next.client_id, client_aum_mv_next.account_group_type ] }

Fragment 61657 (Actor 739516,739515)
StreamLocalityProvider { locality_columns: [clients_dm.id, client_to_account_groups_mv.type] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, 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: [ clients_dm.id, client_to_account_groups_mv.type, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, 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: [ client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.id, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 61658 (Actor 739517,739518)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, 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: [ client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.id, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamHashJoin { type: LeftOuter, predicate: client_to_account_groups_mv.account_group_id = position_snapshot_mv_next.account_group_id AND clients_dm.base_currency_code = position_snapshot_mv_next.currency_code } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_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, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, 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: [ client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.id, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_reference_identifiers_mv.reference_identifiers, client_to_account_groups_mv.$src, client_reference_identifiers_mv.client_id ], stream key: [ client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.id, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    └── 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.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_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 61659 (Actor 739797,739796)
StreamLocalityProvider { locality_columns: [client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_reference_identifiers_mv.reference_identifiers, client_to_account_groups_mv.$src, client_reference_identifiers_mv.client_id ], stream key: [ client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, clients_dm.id, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_reference_identifiers_mv.reference_identifiers, client_to_account_groups_mv.$src, client_reference_identifiers_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }

Fragment 61660 (Actor 739798,739799)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_reference_identifiers_mv.reference_identifiers, client_to_account_groups_mv.$src, client_reference_identifiers_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_reference_identifiers_mv.client_id } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_reference_identifiers_mv.reference_identifiers, client_to_account_groups_mv.$src, client_reference_identifiers_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_to_account_groups_mv.$src, client_task_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ client_reference_identifiers_mv.client_id, client_reference_identifiers_mv.reference_identifiers ], stream key: [ client_reference_identifiers_mv.client_id ] }

Fragment 61661 (Actor 739809,739808)
StreamLocalityProvider { locality_columns: [clients_dm.id] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_to_account_groups_mv.$src, client_task_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_to_account_groups_mv.$src, client_task_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }

Fragment 61662 (Actor 739811,739810)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_to_account_groups_mv.$src, client_task_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_task_counts_mv.client_id } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count, client_to_account_groups_mv.$src, client_task_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_to_account_groups_mv.$src, client_contact_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ client_task_counts_mv.client_id, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count ], stream key: [ client_task_counts_mv.client_id ] }

Fragment 61663 (Actor 739815,739814)
StreamLocalityProvider { locality_columns: [clients_dm.id] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_to_account_groups_mv.$src, client_contact_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_to_account_groups_mv.$src, client_contact_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }

Fragment 61664 (Actor 739812,739813)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_to_account_groups_mv.$src, client_contact_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_contact_counts_mv.client_id } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_contact_counts_mv.contact_count, client_to_account_groups_mv.$src, client_contact_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_to_account_groups_mv.$src, client_portfolio_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ client_contact_counts_mv.client_id, client_contact_counts_mv.contact_count ], stream key: [ client_contact_counts_mv.client_id ] }

Fragment 61665 (Actor 739816,739817)
StreamLocalityProvider { locality_columns: [clients_dm.id] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_to_account_groups_mv.$src, client_portfolio_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_to_account_groups_mv.$src, client_portfolio_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }

Fragment 61666 (Actor 739818,739819)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_to_account_groups_mv.$src, client_portfolio_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_portfolio_counts_mv.client_id } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_portfolio_counts_mv.portfolio_count, client_to_account_groups_mv.$src, client_portfolio_counts_mv.client_id ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_to_account_groups_mv.$src, currencies_dm.code ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ client_portfolio_counts_mv.client_id, client_portfolio_counts_mv.portfolio_count ], stream key: [ client_portfolio_counts_mv.client_id ] }

Fragment 61667 (Actor 739821,739820)
StreamLocalityProvider { locality_columns: [clients_dm.id] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_to_account_groups_mv.$src, currencies_dm.code ], stream key: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_to_account_groups_mv.$src, currencies_dm.code ], stream key: [ clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }

Fragment 61668 (Actor 740042,740041)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: clients_dm.base_currency_code = currencies_dm.code, nested_loop: false } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, client_to_account_groups_mv.$src, currencies_dm.code ], stream key: [ clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ currencies_dm.code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol ], stream key: [ currencies_dm.code ] }

Fragment 61669 (Actor 739823,739822)
StreamLocalityProvider { locality_columns: [clients_dm.base_currency_code] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.base_currency_code, clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }

Fragment 61670 (Actor 737559,737558)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: clients_dm.status_label_id = labels_dm.label_id, nested_loop: false } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ labels_dm.label_id ] }

Fragment 61671 (Actor 739825,739824)
StreamLocalityProvider { locality_columns: [clients_dm.status_label_id] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.status_label_id, clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }

Fragment 61672 (Actor 737576,737577)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: clients_dm.segment_label_id = labels_dm.label_id, nested_loop: false } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, client_to_account_groups_mv.$src, labels_dm.label_id ], stream key: [ clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ labels_dm.label_id ] }

Fragment 61673 (Actor 739826,739827)
StreamLocalityProvider { locality_columns: [clients_dm.segment_label_id] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.segment_label_id, clients_dm.id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src ] }

Fragment 61674 (Actor 739830,739831)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src ] }
└── StreamHashJoin { type: Inner, predicate: clients_dm.id = client_to_account_groups_mv.client_id } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at ], stream key: [ clients_dm.id ] }
    └── MergeExecutor { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }

Fragment 61675 (Actor 739833,739832)
StreamProject { exprs: [clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at ], stream key: [ clients_dm.id ] }
└── StreamFilter { predicate: IsNull(clients_dm.closing_date) AND IsNull(clients_dm.disabled_at) } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, clients_dm.closing_date, clients_dm.disabled_at ], stream key: [ clients_dm.id ] }
    └── StreamTableScan { table: clients_dm, columns: [id, display_name, local_display_name, preferred_name, base_currency_code, customer_identification_file, type, segment_label_id, status_label_id, prefix, suffix, first_name, last_name, onboarding_date, next_kyc_review_date, created_at, closing_date, disabled_at] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.base_currency_code, clients_dm.customer_identification_file, clients_dm.type, clients_dm.segment_label_id, clients_dm.status_label_id, clients_dm.prefix, clients_dm.suffix, clients_dm.first_name, clients_dm.last_name, clients_dm.onboarding_date, clients_dm.next_kyc_review_date, clients_dm.created_at, clients_dm.closing_date, clients_dm.disabled_at ], stream key: [ clients_dm.id ] }
        ├── Upstream { output: [ id, display_name, local_display_name, preferred_name, base_currency_code, customer_identification_file, type, segment_label_id, status_label_id, prefix, suffix, first_name, last_name, onboarding_date, next_kyc_review_date, created_at, closing_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, display_name, local_display_name, preferred_name, base_currency_code, customer_identification_file, type, segment_label_id, status_label_id, prefix, suffix, first_name, last_name, onboarding_date, next_kyc_review_date, created_at, closing_date, disabled_at ], stream key: [] }

Fragment 61676 (Actor 739834,739835)
StreamLocalityProvider { locality_columns: [client_to_account_groups_mv.client_id] } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }

Fragment 61677 (Actor 739837,739836)
StreamTableScan { table: client_to_account_groups_mv, columns: [client_id, account_group_id, type, $src] } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.type, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
├── Upstream { output: [ client_id, account_group_id, type, $src ], stream key: [] }
└── BatchPlanNode { output: [ client_id, account_group_id, type, $src ], stream key: [] }

Fragment 61678 (Actor 737562,737563)
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 61679 (Actor 737566,737567)
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 61680 (Actor 740048,740047)
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 61681 (Actor 739838,739839)
StreamTableScan { table: client_portfolio_counts_mv, columns: [client_id, portfolio_count] } { output: [ client_portfolio_counts_mv.client_id, client_portfolio_counts_mv.portfolio_count ], stream key: [ client_portfolio_counts_mv.client_id ] }
├── Upstream { output: [ client_id, portfolio_count ], stream key: [] }
└── BatchPlanNode { output: [ client_id, portfolio_count ], stream key: [] }

Fragment 61682 (Actor 739840,739841)
StreamTableScan { table: client_contact_counts_mv, columns: [client_id, contact_count] } { output: [ client_contact_counts_mv.client_id, client_contact_counts_mv.contact_count ], stream key: [ client_contact_counts_mv.client_id ] }
├── Upstream { output: [ client_id, contact_count ], stream key: [] }
└── BatchPlanNode { output: [ client_id, contact_count ], stream key: [] }

Fragment 61683 (Actor 739843,739842)
StreamTableScan { table: client_task_counts_mv, columns: [client_id, active_count, high_priority_count] } { output: [ client_task_counts_mv.client_id, client_task_counts_mv.active_count, client_task_counts_mv.high_priority_count ], stream key: [ client_task_counts_mv.client_id ] }
├── Upstream { output: [ client_id, active_count, high_priority_count ], stream key: [] }
└── BatchPlanNode { output: [ client_id, active_count, high_priority_count ], stream key: [] }

Fragment 61684 (Actor 739846,739847)
StreamTableScan { table: client_reference_identifiers_mv, columns: [client_id, reference_identifiers] } { output: [ client_reference_identifiers_mv.client_id, client_reference_identifiers_mv.reference_identifiers ], stream key: [ client_reference_identifiers_mv.client_id ] }
├── Upstream { output: [ client_id, reference_identifiers ], stream key: [] }
└── BatchPlanNode { output: [ client_id, reference_identifiers ], stream key: [] }

Fragment 61685 (Actor 739850,739851)
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.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_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.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_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 61686 (Actor 739853,739852)
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.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_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.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_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.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_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, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_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.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_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, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_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, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv.type_expanded, flag, position_type ], stream key: [] }

Fragment 61687 (Actor 739855,739854)
StreamTableScan { table: client_aum_mv_next, columns: [client_id, account_group_type, aum_market_value, fair_aum_market_value, aum_market_value_system_currency, fair_aum_market_value_system_currency] } { output: [ client_aum_mv_next.client_id, client_aum_mv_next.account_group_type, client_aum_mv_next.aum_market_value, client_aum_mv_next.fair_aum_market_value, client_aum_mv_next.aum_market_value_system_currency, client_aum_mv_next.fair_aum_market_value_system_currency ], stream key: [ client_aum_mv_next.client_id, client_aum_mv_next.account_group_type ] }
├── Upstream { output: [ client_id, account_group_type, aum_market_value, fair_aum_market_value, aum_market_value_system_currency, fair_aum_market_value_system_currency ], stream key: [] }
└── BatchPlanNode { output: [ client_id, account_group_type, aum_market_value, fair_aum_market_value, aum_market_value_system_currency, fair_aum_market_value_system_currency ], stream key: [] }

Fragment 61688 (Actor 739856,739857)
StreamTableScan { table: client_fee_totals_mv_next, columns: [client_id, account_group_type, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency] } { output: [ client_fee_totals_mv_next.client_id, client_fee_totals_mv_next.account_group_type, client_fee_totals_mv_next.total_fees, client_fee_totals_mv_next.transactional_fees, client_fee_totals_mv_next.non_transactional_fees, client_fee_totals_mv_next.total_fees_system_currency, client_fee_totals_mv_next.transactional_fees_system_currency, client_fee_totals_mv_next.non_transactional_fees_system_currency ], stream key: [ client_fee_totals_mv_next.client_id, client_fee_totals_mv_next.account_group_type ] }
├── Upstream { output: [ client_id, account_group_type, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency ], stream key: [] }
└── BatchPlanNode { output: [ client_id, account_group_type, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency ], stream key: [] }