party_clients_sink · explain

← cluster alinma_bff objects party_clients_sink explain
Overview Objects Graph History
sink · alinma_bff.party_clients_sink 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
19 operators
Sink · alinma_bff.party_clients_sink
0% idle 2 actors
Project · upsert
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · book_of_business_party_clients_mv_next.party_id = party_ref…
— — 2 actors
HashJoin · LeftOuter · book_of_business_party_clients_mv_next.party_id = party_ref… 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 · party_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
StreamScan · book_of_business_party_clients_mv_next
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 61611 (Actor 739619,739620)
StreamSink { type: upsert, columns: [party_id, party_type, base_currency_code, created_at, onboarding_date, closing_date, customer_relationship_status, reference_identifiers, customer_identification_file, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, 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, task_overdue_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, book_of_business_party_clients_mv_next.parties.id(hidden), book_of_business_party_clients_mv_next.'all':Varchar(hidden), book_of_business_party_clients_mv_next.$expr1(hidden), book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code)(hidden), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id)(hidden), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id)(hidden), book_of_business_party_clients_mv_next.$src(hidden), book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded(hidden), book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag(hidden), book_of_business_party_clients_mv_next.$src#1(hidden)], downstream_pk: [book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.account_group_type] }
├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, $expr1, party_reference_identifiers_mv.customer_identification_file, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
├── stream key: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
└── StreamProject
└─exprs:
  ┌─book_of_business_party_clients_mv_next.party_id
  ├─book_of_business_party_clients_mv_next.party_type
  ├─book_of_business_party_clients_mv_next.base_currency_code
  ├─book_of_business_party_clients_mv_next.created_at
  ├─book_of_business_party_clients_mv_next.onboarding_date
  ├─book_of_business_party_clients_mv_next.closing_date
  ├─book_of_business_party_clients_mv_next.customer_relationship_status
  ├─Coalesce(party_reference_identifiers_mv.reference_identifiers, '[]':Jsonb) as $expr1
  ├─party_reference_identifiers_mv.customer_identification_file
  ├─book_of_business_party_clients_mv_next.account_group_type
  ├─book_of_business_party_clients_mv_next.display_name
  ├─book_of_business_party_clients_mv_next.local_display_name
  ├─book_of_business_party_clients_mv_next.preferred_name
  ├─book_of_business_party_clients_mv_next.prefix
  ├─book_of_business_party_clients_mv_next.suffix
  ├─book_of_business_party_clients_mv_next.first_name
  ├─book_of_business_party_clients_mv_next.last_name
  ├─book_of_business_party_clients_mv_next.segment_id
  ├─book_of_business_party_clients_mv_next.segment_name_en
  ├─book_of_business_party_clients_mv_next.segment_name_ar
  ├─book_of_business_party_clients_mv_next.segment_color
  ├─book_of_business_party_clients_mv_next.status_label_id
  ├─book_of_business_party_clients_mv_next.status_name_en
  ├─book_of_business_party_clients_mv_next.status_name_ar
  ├─book_of_business_party_clients_mv_next.status_color
  ├─book_of_business_party_clients_mv_next.currency_code
  ├─book_of_business_party_clients_mv_next.currency_name_en
  ├─book_of_business_party_clients_mv_next.currency_name_ar
  ├─book_of_business_party_clients_mv_next.currency_symbol
  ├─book_of_business_party_clients_mv_next.portfolio_count
  ├─book_of_business_party_clients_mv_next.contact_count
  ├─book_of_business_party_clients_mv_next.task_active_count
  ├─book_of_business_party_clients_mv_next.task_high_priority_count
  ├─book_of_business_party_clients_mv_next.task_overdue_count
  ├─book_of_business_party_clients_mv_next.market_value
  ├─book_of_business_party_clients_mv_next.fair_value
  ├─book_of_business_party_clients_mv_next.relationship_value
  ├─book_of_business_party_clients_mv_next.fair_relationship_value
  ├─book_of_business_party_clients_mv_next.market_value_system_currency
  ├─book_of_business_party_clients_mv_next.fair_value_system_currency
  ├─book_of_business_party_clients_mv_next.relationship_value_system_currency
  ├─book_of_business_party_clients_mv_next.fair_relationship_value_system_currency
  ├─book_of_business_party_clients_mv_next.aum_value
  ├─book_of_business_party_clients_mv_next.fair_aum_value
  ├─book_of_business_party_clients_mv_next.aum_value_system_currency
  ├─book_of_business_party_clients_mv_next.fair_aum_value_system_currency
  ├─book_of_business_party_clients_mv_next.total_fees
  ├─book_of_business_party_clients_mv_next.transactional_fees
  ├─book_of_business_party_clients_mv_next.non_transactional_fees
  ├─book_of_business_party_clients_mv_next.total_fees_system_currency
  ├─book_of_business_party_clients_mv_next.transactional_fees_system_currency
  ├─book_of_business_party_clients_mv_next.non_transactional_fees_system_currency
  ├─book_of_business_party_clients_mv_next.parties.id
  ├─book_of_business_party_clients_mv_next.'all':Varchar
  ├─book_of_business_party_clients_mv_next.$expr1
  ├─book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code)
  ├─book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id)
  ├─book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id)
  ├─book_of_business_party_clients_mv_next.$src
  ├─book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded
  ├─book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag
  └─book_of_business_party_clients_mv_next.$src#1
    ├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, $expr1, party_reference_identifiers_mv.customer_identification_file, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
    ├── stream key: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
    └── MergeExecutor
        ├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, party_reference_identifiers_mv.customer_identification_file, party_reference_identifiers_mv.reference_identifiers, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1, party_reference_identifiers_mv.party_id ]
        └── stream key: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]

Fragment 61612 (Actor 739618,739617)
StreamSyncLogStore
├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, party_reference_identifiers_mv.customer_identification_file, party_reference_identifiers_mv.reference_identifiers, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1, party_reference_identifiers_mv.party_id ]
├── stream key: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
└── StreamHashJoin { type: LeftOuter, predicate: book_of_business_party_clients_mv_next.party_id = party_reference_identifiers_mv.party_id }
    ├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, party_reference_identifiers_mv.customer_identification_file, party_reference_identifiers_mv.reference_identifiers, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1, party_reference_identifiers_mv.party_id ]
    ├── stream key: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
    ├── MergeExecutor
    │   ├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
    │   └── stream key: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
    └── MergeExecutor { output: [ party_reference_identifiers_mv.party_id, party_reference_identifiers_mv.customer_identification_file, party_reference_identifiers_mv.reference_identifiers ], stream key: [ party_reference_identifiers_mv.party_id ] }

Fragment 61613 (Actor 739621,739622)
StreamLocalityProvider { locality_columns: [book_of_business_party_clients_mv_next.party_id] }
├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
├── stream key: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
└── MergeExecutor
    ├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
    └── stream key: [ book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]

Fragment 61614 (Actor 739626,739625)
StreamTableScan { table: book_of_business_party_clients_mv_next, columns: [party_id, party_type, base_currency_code, created_at, onboarding_date, closing_date, customer_relationship_status, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, status_label_id, status_name_en, status_name_ar, status_color, segment_id, segment_name_en, segment_name_ar, segment_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, task_overdue_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, parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, $src#1] }
├── output: [ book_of_business_party_clients_mv_next.party_id, book_of_business_party_clients_mv_next.party_type, book_of_business_party_clients_mv_next.base_currency_code, book_of_business_party_clients_mv_next.created_at, book_of_business_party_clients_mv_next.onboarding_date, book_of_business_party_clients_mv_next.closing_date, book_of_business_party_clients_mv_next.customer_relationship_status, book_of_business_party_clients_mv_next.account_group_type, book_of_business_party_clients_mv_next.display_name, book_of_business_party_clients_mv_next.local_display_name, book_of_business_party_clients_mv_next.preferred_name, book_of_business_party_clients_mv_next.prefix, book_of_business_party_clients_mv_next.suffix, book_of_business_party_clients_mv_next.first_name, book_of_business_party_clients_mv_next.last_name, book_of_business_party_clients_mv_next.status_label_id, book_of_business_party_clients_mv_next.status_name_en, book_of_business_party_clients_mv_next.status_name_ar, book_of_business_party_clients_mv_next.status_color, book_of_business_party_clients_mv_next.segment_id, book_of_business_party_clients_mv_next.segment_name_en, book_of_business_party_clients_mv_next.segment_name_ar, book_of_business_party_clients_mv_next.segment_color, book_of_business_party_clients_mv_next.currency_code, book_of_business_party_clients_mv_next.currency_name_en, book_of_business_party_clients_mv_next.currency_name_ar, book_of_business_party_clients_mv_next.currency_symbol, book_of_business_party_clients_mv_next.portfolio_count, book_of_business_party_clients_mv_next.contact_count, book_of_business_party_clients_mv_next.task_active_count, book_of_business_party_clients_mv_next.task_high_priority_count, book_of_business_party_clients_mv_next.task_overdue_count, book_of_business_party_clients_mv_next.market_value, book_of_business_party_clients_mv_next.fair_value, book_of_business_party_clients_mv_next.relationship_value, book_of_business_party_clients_mv_next.fair_relationship_value, book_of_business_party_clients_mv_next.market_value_system_currency, book_of_business_party_clients_mv_next.fair_value_system_currency, book_of_business_party_clients_mv_next.relationship_value_system_currency, book_of_business_party_clients_mv_next.fair_relationship_value_system_currency, book_of_business_party_clients_mv_next.aum_value, book_of_business_party_clients_mv_next.fair_aum_value, book_of_business_party_clients_mv_next.aum_value_system_currency, book_of_business_party_clients_mv_next.fair_aum_value_system_currency, book_of_business_party_clients_mv_next.total_fees, book_of_business_party_clients_mv_next.transactional_fees, book_of_business_party_clients_mv_next.non_transactional_fees, book_of_business_party_clients_mv_next.total_fees_system_currency, book_of_business_party_clients_mv_next.transactional_fees_system_currency, book_of_business_party_clients_mv_next.non_transactional_fees_system_currency, book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
├── stream key: [ book_of_business_party_clients_mv_next.parties.id, book_of_business_party_clients_mv_next.'all':Varchar, book_of_business_party_clients_mv_next.$expr1, book_of_business_party_clients_mv_next.min(lifecycle_profiles.base_currency_code), book_of_business_party_clients_mv_next.min(lifecycle_profiles.segment_id), book_of_business_party_clients_mv_next.min(customer_relationships.status_label_id), book_of_business_party_clients_mv_next.$src, book_of_business_party_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_party_clients_mv_next.position_snapshot_mv_next.flag, book_of_business_party_clients_mv_next.$src#1 ]
├── Upstream { output: [ party_id, party_type, base_currency_code, created_at, onboarding_date, closing_date, customer_relationship_status, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, status_label_id, status_name_en, status_name_ar, status_color, segment_id, segment_name_en, segment_name_ar, segment_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, task_overdue_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, parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, $src#1 ], stream key: [] }
└── BatchPlanNode { output: [ party_id, party_type, base_currency_code, created_at, onboarding_date, closing_date, customer_relationship_status, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, status_label_id, status_name_en, status_name_ar, status_color, segment_id, segment_name_en, segment_name_ar, segment_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, task_overdue_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, parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, $src#1 ], stream key: [] }

Fragment 61615 (Actor 739628,739627)
StreamTableScan { table: party_reference_identifiers_mv, columns: [party_id, customer_identification_file, reference_identifiers] } { output: [ party_reference_identifiers_mv.party_id, party_reference_identifiers_mv.customer_identification_file, party_reference_identifiers_mv.reference_identifiers ], stream key: [ party_reference_identifiers_mv.party_id ] }
├── Upstream { output: [ party_id, customer_identification_file, reference_identifiers ], stream key: [] }
└── BatchPlanNode { output: [ party_id, customer_identification_file, reference_identifiers ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
