book_of_business_clients_mv · explain

← 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
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
Heat tree Operator graph
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.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 64074 (Actor 743715,743716)
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_next.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_next.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_next.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_next.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_next.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_next.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_next.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_next.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_next.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_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 64075 (Actor 743717,743718)
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_next.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_next.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_next.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_next.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_next.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_next.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 64076 (Actor 743720,743719)
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_next.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_next.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_next.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_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 64077 (Actor 743721,743722)
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_next.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_next.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_next.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_next.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_next.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_next.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 64078 (Actor 743723,743724)
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_next.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_next.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_next.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_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 64079 (Actor 743725,743726)
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_next.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_next.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_next.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_next.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_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 64080 (Actor 743727,743728)
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 64081 (Actor 743729,743730)
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 64082 (Actor 747038,747039)
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 64083 (Actor 747037,747036)
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 64084 (Actor 747042,747043)
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 64085 (Actor 747041,747040)
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 64086 (Actor 747045,747044)
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 64087 (Actor 747047,747046)
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 64088 (Actor 747048,747049)
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 64089 (Actor 741751,741752)
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 64090 (Actor 743835,743836)
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 64091 (Actor 742281,742282)
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 64092 (Actor 744024,744023)
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 64093 (Actor 742291,742292)
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 64094 (Actor 744096,744095)
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 64095 (Actor 747050,747051)
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 64096 (Actor 747053,747052)
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 64097 (Actor 747054,747055)
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 64098 (Actor 747057,747056)
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 64099 (Actor 742283,742284)
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 64100 (Actor 742279,742280)
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 64101 (Actor 741742,741741)
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 64102 (Actor 747058,747059)
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 64103 (Actor 747060,747061)
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 64104 (Actor 747062,747063)
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 64105 (Actor 747064,747065)
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 64106 (Actor 747066,747067)
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_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.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_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 64107 (Actor 747069,747068)
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_next.type_expanded, position_snapshot_mv_next.flag] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.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_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamFilter { predicate: (position_snapshot_mv_next.position_type = 'POSITION':Varchar) } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.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_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
    └── StreamTableScan { table: position_snapshot_mv_next, columns: [account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.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_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
        ├── Upstream { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }
        └── BatchPlanNode { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }

Fragment 64108 (Actor 747070,747071)
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 64109 (Actor 747072,747073)
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: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
