Fragment 61471 (Actor 738981,738982)
StreamMaterialize { 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, $src(hidden), position_snapshot_mv_next.flag(hidden), parties.id(hidden), 'all':Varchar(hidden), $expr1(hidden), min(lifecycle_profiles.base_currency_code)(hidden), min(lifecycle_profiles.segment_id)(hidden), min(customer_relationships.status_label_id)(hidden), position_snapshot_mv_next.holding_values_latest_mv.type_expanded(hidden), $src#1(hidden)], stream_key: [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], pk_columns: [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], pk_conflict: NoCheck }
├── output: [ parties.id, parties.type, min(lifecycle_profiles.base_currency_code), null:Timestamptz, min(lifecycle_profiles.onboarding_date), null:Date, 'ACTIVE':Varchar, 'all':Varchar, parties.display_name, null:Varchar, null:Varchar, party_individual.salutation, party_individual.suffix, party_individual.first_name, party_individual.last_name, min(customer_relationships.status_label_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.segment_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.base_currency_code), currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, $expr15, $expr16, $expr17, $expr18, $expr19, $expr20, $expr21, $expr22, $expr23, $expr24, $expr25, $expr26, $expr27, $src, position_snapshot_mv_next.flag, parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), position_snapshot_mv_next.holding_values_latest_mv.type_expanded, $src ]
├── stream key: [ 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 ]
└── StreamUnion { all: true } { output: [ parties.id, parties.type, min(lifecycle_profiles.base_currency_code), null:Timestamptz, min(lifecycle_profiles.onboarding_date), null:Date, 'ACTIVE':Varchar, 'all':Varchar, parties.display_name, null:Varchar, null:Varchar, party_individual.salutation, party_individual.suffix, party_individual.first_name, party_individual.last_name, min(customer_relationships.status_label_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.segment_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.base_currency_code), currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, $expr15, $expr16, $expr17, $expr18, $expr19, $expr20, $expr21, $expr22, $expr23, $expr24, $expr25, $expr26, $expr27, $src, position_snapshot_mv_next.flag, parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), position_snapshot_mv_next.holding_values_latest_mv.type_expanded, $src ], stream key: [ 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 ] }
├── MergeExecutor { output: [ parties.id, parties.type, min(lifecycle_profiles.base_currency_code), null:Timestamptz, min(lifecycle_profiles.onboarding_date), null:Date, 'ACTIVE':Varchar, 'all':Varchar, parties.display_name, null:Varchar, null:Varchar, party_individual.salutation, party_individual.suffix, party_individual.first_name, party_individual.last_name, min(customer_relationships.status_label_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.segment_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.base_currency_code), currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, $expr15, $expr16, $expr17, $expr18, $expr19, $expr20, $expr21, $expr22, $expr23, $expr24, $expr25, $expr26, $expr27, $src, position_snapshot_mv_next.flag, parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), position_snapshot_mv_next.holding_values_latest_mv.type_expanded, 0:Int32 ], stream key: [ 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 ] }
└── MergeExecutor { output: [ parties.id, parties.type, min(lifecycle_profiles.base_currency_code), null:Timestamptz, min(lifecycle_profiles.onboarding_date), null:Date, 'DRAFT':Varchar, 'none':Varchar, parties.display_name, null:Varchar, null:Varchar, party_individual.salutation, party_individual.suffix, party_individual.first_name, party_individual.last_name, min(customer_relationships.status_label_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.segment_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.base_currency_code), currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, 0:Int64, $expr30, 0:Int64, 0:Int64, 0:Int64, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, null:Int32, null:Int64, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
Fragment 61472 (Actor 738984,738983)
StreamProject
└─exprs:
┌─parties.id
├─parties.type
├─min(lifecycle_profiles.base_currency_code)
├─null:Timestamptz
├─min(lifecycle_profiles.onboarding_date)
├─null:Date
├─'ACTIVE':Varchar
├─'all':Varchar
├─parties.display_name
├─null:Varchar
├─null:Varchar
├─party_individual.salutation
├─party_individual.suffix
├─party_individual.first_name
├─party_individual.last_name
├─min(customer_relationships.status_label_id)
├─labels_dm.name_en
├─labels_dm.name_ar
├─labels_dm.color
├─min(lifecycle_profiles.segment_id)
├─labels_dm.name_en
├─labels_dm.name_ar
├─labels_dm.color
├─min(lifecycle_profiles.base_currency_code)
├─currencies_dm.name_en
├─currencies_dm.name_ar
├─currencies_dm.symbol
├─Coalesce(party_portfolio_counts_mv.portfolio_count::Int64, 0:Int64) as $expr5
├─Coalesce(party_contact_counts_mv.contact_count, 0:Int64) as $expr6
├─Coalesce(party_task_counts_mv_next.active_count::Int64, 0:Int64) as $expr7
├─Coalesce(party_task_counts_mv_next.high_priority_count::Int64, 0:Int64) as $expr8
├─Coalesce(party_task_counts_mv_next.overdue_count::Int64, 0:Int64) as $expr9
├─Coalesce(position_snapshot_mv_next.market_value, 0:Decimal) as $expr10
├─Coalesce(position_snapshot_mv_next.fair_value, 0:Decimal) as $expr11
├─Coalesce(position_snapshot_mv_next.relationship_value, 0:Decimal) as $expr12
├─Coalesce(position_snapshot_mv_next.fair_relationship_value, 0:Decimal) as $expr13
├─Coalesce(position_snapshot_mv_next.market_value_system_currency, 0:Decimal) as $expr14
├─Coalesce(position_snapshot_mv_next.fair_value_system_currency, 0:Decimal) as $expr15
├─Coalesce(position_snapshot_mv_next.relationship_value_system_currency, 0:Decimal) as $expr16
├─Coalesce(position_snapshot_mv_next.fair_relationship_value_system_currency, 0:Decimal) as $expr17
├─Coalesce(party_aum_mv.aum_market_value, 0:Decimal) as $expr18
├─Coalesce(party_aum_mv.fair_aum_market_value, 0:Decimal) as $expr19
├─Coalesce(party_aum_mv.aum_market_value_system_currency, 0:Decimal) as $expr20
├─Coalesce(party_aum_mv.fair_aum_market_value_system_currency, 0:Decimal) as $expr21
├─Coalesce(party_fee_totals_mv.total_fees, 0:Decimal) as $expr22
├─Coalesce(party_fee_totals_mv.transactional_fees, 0:Decimal) as $expr23
├─Coalesce(party_fee_totals_mv.non_transactional_fees, 0:Decimal) as $expr24
├─Coalesce(party_fee_totals_mv.total_fees_system_currency, 0:Decimal) as $expr25
├─Coalesce(party_fee_totals_mv.transactional_fees_system_currency, 0:Decimal) as $expr26
├─Coalesce(party_fee_totals_mv.non_transactional_fees_system_currency, 0:Decimal) as $expr27
├─$src
├─position_snapshot_mv_next.flag
├─parties.id
├─'all':Varchar
├─$expr1
├─min(lifecycle_profiles.base_currency_code)
├─min(lifecycle_profiles.segment_id)
├─min(customer_relationships.status_label_id)
├─position_snapshot_mv_next.holding_values_latest_mv.type_expanded
└─0:Int32
├── output: [ parties.id, parties.type, min(lifecycle_profiles.base_currency_code), null:Timestamptz, min(lifecycle_profiles.onboarding_date), null:Date, 'ACTIVE':Varchar, 'all':Varchar, parties.display_name, null:Varchar, null:Varchar, party_individual.salutation, party_individual.suffix, party_individual.first_name, party_individual.last_name, min(customer_relationships.status_label_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.segment_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.base_currency_code), currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, $expr5, $expr6, $expr7, $expr8, $expr9, $expr10, $expr11, $expr12, $expr13, $expr14, $expr15, $expr16, $expr17, $expr18, $expr19, $expr20, $expr21, $expr22, $expr23, $expr24, $expr25, $expr26, $expr27, $src, position_snapshot_mv_next.flag, parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), position_snapshot_mv_next.holding_values_latest_mv.type_expanded, 0:Int32 ]
├── stream key: [ 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 ]
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, party_fee_totals_mv.total_fees, party_fee_totals_mv.transactional_fees, party_fee_totals_mv.non_transactional_fees, party_fee_totals_mv.total_fees_system_currency, party_fee_totals_mv.transactional_fees_system_currency, party_fee_totals_mv.non_transactional_fees_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_fee_totals_mv.party_id, party_fee_totals_mv.account_group_type ], stream key: [ 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 ] }
Fragment 61473 (Actor 738986,738985)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, party_fee_totals_mv.total_fees, party_fee_totals_mv.transactional_fees, party_fee_totals_mv.non_transactional_fees, party_fee_totals_mv.total_fees_system_currency, party_fee_totals_mv.transactional_fees_system_currency, party_fee_totals_mv.non_transactional_fees_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_fee_totals_mv.party_id, party_fee_totals_mv.account_group_type ], stream key: [ 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 ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_fee_totals_mv.party_id AND 'all':Varchar = party_fee_totals_mv.account_group_type } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, party_fee_totals_mv.total_fees, party_fee_totals_mv.transactional_fees, party_fee_totals_mv.non_transactional_fees, party_fee_totals_mv.total_fees_system_currency, party_fee_totals_mv.transactional_fees_system_currency, party_fee_totals_mv.non_transactional_fees_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_fee_totals_mv.party_id, party_fee_totals_mv.account_group_type ], stream key: [ 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 ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_aum_mv.party_id, party_aum_mv.account_group_type ], stream key: [ 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 ] }
└── MergeExecutor { output: [ party_fee_totals_mv.party_id, party_fee_totals_mv.account_group_type, party_fee_totals_mv.total_fees, party_fee_totals_mv.transactional_fees, party_fee_totals_mv.non_transactional_fees, party_fee_totals_mv.total_fees_system_currency, party_fee_totals_mv.transactional_fees_system_currency, party_fee_totals_mv.non_transactional_fees_system_currency ], stream key: [ party_fee_totals_mv.party_id, party_fee_totals_mv.account_group_type ] }
Fragment 61474 (Actor 738990,738989)
StreamLocalityProvider { locality_columns: [parties.id, 'all':Varchar] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_aum_mv.party_id, party_aum_mv.account_group_type ], stream key: [ 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 ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_aum_mv.party_id, party_aum_mv.account_group_type ], stream key: [ 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 ] }
Fragment 61475 (Actor 738987,738988)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_aum_mv.party_id, party_aum_mv.account_group_type ], stream key: [ 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 ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_aum_mv.party_id AND 'all':Varchar = party_aum_mv.account_group_type } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, party_aum_mv.party_id, party_aum_mv.account_group_type ], stream key: [ 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 ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, $expr1, $src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ 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 ] }
└── MergeExecutor { output: [ party_aum_mv.party_id, party_aum_mv.account_group_type, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency ], stream key: [ party_aum_mv.party_id, party_aum_mv.account_group_type ] }
Fragment 61476 (Actor 738992,738991)
StreamLocalityProvider { locality_columns: [parties.id, 'all':Varchar] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, $expr1, $src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ 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 ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, $expr1, $src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ $expr1, min(lifecycle_profiles.base_currency_code), parties.id, 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 ] }
Fragment 61477 (Actor 738993,738994)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, $expr1, $src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ $expr1, min(lifecycle_profiles.base_currency_code), parties.id, 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 ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr1 = position_snapshot_mv_next.account_group_id AND min(lifecycle_profiles.base_currency_code) = position_snapshot_mv_next.currency_code } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, 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, $expr1, $src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ $expr1, min(lifecycle_profiles.base_currency_code), parties.id, 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 ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, $src, party_task_counts_mv_next.party_id ], stream key: [ $expr1, min(lifecycle_profiles.base_currency_code), parties.id, min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
Fragment 61478 (Actor 738995,738996)
StreamLocalityProvider { locality_columns: [$expr1, min(lifecycle_profiles.base_currency_code)] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, $src, party_task_counts_mv_next.party_id ], stream key: [ $expr1, min(lifecycle_profiles.base_currency_code), parties.id, min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, $src, party_task_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
Fragment 61479 (Actor 738998,738997)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, $src, party_task_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_task_counts_mv_next.party_id } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count, $src, party_task_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, $src, party_contact_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ party_task_counts_mv_next.party_id, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count ], stream key: [ party_task_counts_mv_next.party_id ] }
Fragment 61480 (Actor 739000,738999)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, $src, party_contact_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, $src, party_contact_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
Fragment 61481 (Actor 739002,739001)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, $src, party_contact_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_contact_counts_mv.party_id } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, party_contact_counts_mv.contact_count, $src, party_contact_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, $src, party_portfolio_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ party_contact_counts_mv.party_id ] }
Fragment 61482 (Actor 739195,739194)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, $src, party_portfolio_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, $src, party_portfolio_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
Fragment 61483 (Actor 739193,739192)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, $src, party_portfolio_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_portfolio_counts_mv.party_id } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, party_portfolio_counts_mv.portfolio_count, $src, party_portfolio_counts_mv.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, $src, currencies_dm.code ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ party_portfolio_counts_mv.party_id, party_portfolio_counts_mv.portfolio_count ], stream key: [ party_portfolio_counts_mv.party_id ] }
Fragment 61484 (Actor 739197,739196)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, $src, currencies_dm.code ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, $src, currencies_dm.code ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $src ] }
Fragment 61485 (Actor 740055,740056)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(lifecycle_profiles.base_currency_code) = currencies_dm.code, nested_loop: false } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, 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, $src, currencies_dm.code ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $src ] }
└── MergeExecutor { output: [ currencies_dm.code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol ], stream key: [ currencies_dm.code ] }
Fragment 61486 (Actor 739199,739198)
StreamLocalityProvider { locality_columns: [min(lifecycle_profiles.base_currency_code)] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $src ] }
Fragment 61487 (Actor 737571,737570)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(lifecycle_profiles.segment_id) = labels_dm.label_id, nested_loop: false } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $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 61488 (Actor 739201,739200)
StreamLocalityProvider { locality_columns: [min(lifecycle_profiles.segment_id)] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(customer_relationships.status_label_id), parties.id, $src ] }
Fragment 61489 (Actor 737590,737591)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(customer_relationships.status_label_id) = labels_dm.label_id, nested_loop: false } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, $src, labels_dm.label_id ], stream key: [ min(customer_relationships.status_label_id), parties.id, $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, $src, party_individual.party_id ], stream key: [ min(customer_relationships.status_label_id), parties.id, $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 61490 (Actor 739203,739202)
StreamLocalityProvider { locality_columns: [min(customer_relationships.status_label_id)] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, $src, party_individual.party_id ], stream key: [ min(customer_relationships.status_label_id), parties.id, $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, $src, party_individual.party_id ], stream key: [ parties.id, $src ] }
Fragment 61491 (Actor 739204,739205)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, $src, party_individual.party_id ], stream key: [ parties.id, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_individual.party_id } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, $src, party_individual.party_id ], stream key: [ parties.id, $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv.party_id, $src ], stream key: [ parties.id, $src ] }
└── MergeExecutor { output: [ party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ party_individual.party_id ] }
Fragment 61492 (Actor 739206,739207)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv.party_id, $src ], stream key: [ parties.id, $src ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv.party_id, $src ], stream key: [ parties.id, $src ] }
Fragment 61493 (Actor 739209,739208)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv.party_id, $src ], stream key: [ parties.id, $src ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = party_active_customer_relationships_mv.party_id } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv.party_id, $src ], stream key: [ parties.id, $src ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv.party_id, $src ] }
Fragment 61494 (Actor 739210,739211)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv.party_id ], stream key: [ parties.id ] }
Fragment 61495 (Actor 739213,739212)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv.party_id ], stream key: [ parties.id ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = party_active_customer_relationships_mv.party_id } { output: [ parties.id, parties.type, parties.display_name, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv.party_id ], stream key: [ parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61496 (Actor 739214,739215)
StreamProject { exprs: [parties.id, parties.type, parties.display_name] } { output: [ parties.id, parties.type, parties.display_name ], stream key: [ parties.id ] }
└── StreamFilter { predicate: IsNull(parties.disabled_at) } { output: [ parties.id, parties.type, parties.display_name, parties.disabled_at ], stream key: [ parties.id ] }
└── StreamTableScan { table: parties, columns: [id, type, display_name, disabled_at] } { output: [ parties.id, parties.type, parties.display_name, parties.disabled_at ], stream key: [ parties.id ] }
├── Upstream { output: [ id, type, display_name, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ id, type, display_name, disabled_at ], stream key: [] }
Fragment 61497 (Actor 739234,739235)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv.party_id] } { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61498 (Actor 739245,739244)
StreamNoOp { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61499 (Actor 739242,739243)
StreamProject { exprs: [party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar] } { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── StreamHashAgg { group_key: [party_active_customer_relationships_mv.party_id], aggs: [min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), count] } { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), count ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv.party_id] } { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61500 (Actor 739305,739304)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61501 (Actor 739300,739301)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61502 (Actor 739299,739298)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61503 (Actor 739306,739307)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61504 (Actor 739302,739303)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61505 (Actor 739308,739309)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: party_active_customer_relationships_mv.customer_relationship_id = lifecycle_profiles.customer_relationship_id } { output: [ party_active_customer_relationships_mv.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id, lifecycle_profiles.id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61506 (Actor 739322,739323)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv.customer_relationship_id] } { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
Fragment 61507 (Actor 739320,739321)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
Fragment 61508 (Actor 739319,739318)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
Fragment 61509 (Actor 739314,739315)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
Fragment 61510 (Actor 739325,739324)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
Fragment 61511 (Actor 739316,739317)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
Fragment 61512 (Actor 739312,739313)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── StreamHashJoin { type: Inner, predicate: party_active_customer_relationships_mv.customer_relationship_id = customer_relationships.id } { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id, customer_relationships.status_label_id, customer_relationships.id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
└── MergeExecutor { output: [ customer_relationships.id, customer_relationships.status_label_id ], stream key: [ customer_relationships.id ] }
Fragment 61513 (Actor 739327,739326)
StreamTableScan { table: party_active_customer_relationships_mv, columns: [party_id, customer_relationship_id] } { output: [ party_active_customer_relationships_mv.party_id, party_active_customer_relationships_mv.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv.customer_relationship_id ] }
├── Upstream { output: [ party_id, customer_relationship_id ], stream key: [] }
└── BatchPlanNode { output: [ party_id, customer_relationship_id ], stream key: [] }
Fragment 61514 (Actor 739328,739329)
StreamTableScan { table: customer_relationships, columns: [id, status_label_id] } { output: [ customer_relationships.id, customer_relationships.status_label_id ], stream key: [ customer_relationships.id ] }
├── Upstream { output: [ id, status_label_id ], stream key: [] }
└── BatchPlanNode { output: [ id, status_label_id ], stream key: [] }
Fragment 61515 (Actor 739330,739331)
StreamLocalityProvider { locality_columns: [lifecycle_profiles.customer_relationship_id] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.id ] }
Fragment 61516 (Actor 739332,739333)
StreamProject { exprs: [lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.id ] }
└── StreamFilter { predicate: IsNull(lifecycle_profiles.disabled_at) } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id, lifecycle_profiles.disabled_at ], stream key: [ lifecycle_profiles.id ] }
└── StreamTableScan { table: lifecycle_profiles, columns: [customer_relationship_id, base_currency_code, onboarding_date, segment_id, id, disabled_at] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id, lifecycle_profiles.disabled_at ], stream key: [ lifecycle_profiles.id ] }
├── Upstream { output: [ customer_relationship_id, base_currency_code, onboarding_date, segment_id, id, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ customer_relationship_id, base_currency_code, onboarding_date, segment_id, id, disabled_at ], stream key: [] }
Fragment 61517 (Actor 739334,739335)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv.party_id] } { output: [ party_active_customer_relationships_mv.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv.party_id, $src ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv.party_id, $src ] }
Fragment 61518 (Actor 739336,739337)
StreamUnion { all: true } { output: [ party_active_customer_relationships_mv.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv.party_id, $src ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, $expr1, 'all':Varchar, 0:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, $expr2, 'restricted':Varchar, 1:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, $expr3, 'un_restricted':Varchar, 2:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, $expr4, 'none':Varchar, 3:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61519 (Actor 739237,739236)
StreamProject { exprs: [party_active_customer_relationships_mv.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv.party_id, 'all':Varchar)::Bytea)) as $expr1, 'all':Varchar, 0:Int32] } { output: [ party_active_customer_relationships_mv.party_id, $expr1, 'all':Varchar, 0:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61520 (Actor 739249,739248)
StreamProject { exprs: [party_active_customer_relationships_mv.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv.party_id, 'restricted':Varchar)::Bytea)) as $expr2, 'restricted':Varchar, 1:Int32] } { output: [ party_active_customer_relationships_mv.party_id, $expr2, 'restricted':Varchar, 1:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61521 (Actor 739250,739251)
StreamProject { exprs: [party_active_customer_relationships_mv.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv.party_id, 'un_restricted':Varchar)::Bytea)) as $expr3, 'un_restricted':Varchar, 2:Int32] } { output: [ party_active_customer_relationships_mv.party_id, $expr3, 'un_restricted':Varchar, 2:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61522 (Actor 739247,739246)
StreamProject { exprs: [party_active_customer_relationships_mv.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv.party_id, 'none':Varchar)::Bytea)) as $expr4, 'none':Varchar, 3:Int32] } { output: [ party_active_customer_relationships_mv.party_id, $expr4, 'none':Varchar, 3:Int32 ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61523 (Actor 739355,739354)
StreamTableScan { table: party_individual, columns: [party_id, salutation, first_name, last_name, suffix] } { output: [ party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ party_individual.party_id ] }
├── Upstream { output: [ party_id, salutation, first_name, last_name, suffix ], stream key: [] }
└── BatchPlanNode { output: [ party_id, salutation, first_name, last_name, suffix ], stream key: [] }
Fragment 61524 (Actor 737583,737582)
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 61525 (Actor 737588,737589)
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 61526 (Actor 740053,740054)
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 61527 (Actor 739362,739363)
StreamTableScan { table: party_portfolio_counts_mv, columns: [party_id, portfolio_count] } { output: [ party_portfolio_counts_mv.party_id, party_portfolio_counts_mv.portfolio_count ], stream key: [ party_portfolio_counts_mv.party_id ] }
├── Upstream { output: [ party_id, portfolio_count ], stream key: [] }
└── BatchPlanNode { output: [ party_id, portfolio_count ], stream key: [] }
Fragment 61528 (Actor 739366,739367)
StreamTableScan { table: party_contact_counts_mv, columns: [party_id, contact_count] } { output: [ party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ party_contact_counts_mv.party_id ] }
├── Upstream { output: [ party_id, contact_count ], stream key: [] }
└── BatchPlanNode { output: [ party_id, contact_count ], stream key: [] }
Fragment 61529 (Actor 739369,739368)
StreamTableScan { table: party_task_counts_mv_next, columns: [party_id, active_count, high_priority_count, overdue_count] } { output: [ party_task_counts_mv_next.party_id, party_task_counts_mv_next.active_count, party_task_counts_mv_next.high_priority_count, party_task_counts_mv_next.overdue_count ], stream key: [ party_task_counts_mv_next.party_id ] }
├── Upstream { output: [ party_id, active_count, high_priority_count, overdue_count ], stream key: [] }
└── BatchPlanNode { output: [ party_id, active_count, high_priority_count, overdue_count ], stream key: [] }
Fragment 61530 (Actor 739371,739370)
StreamLocalityProvider { locality_columns: [position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
Fragment 61531 (Actor 739373,739372)
StreamProject { exprs: [position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamFilter { predicate: (position_snapshot_mv_next.position_type = 'POSITION':Varchar) } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamTableScan { table: position_snapshot_mv_next, columns: [account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv.type_expanded, flag, position_type] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ] }
├── Upstream { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv.type_expanded, flag, position_type ], stream key: [] }
└── BatchPlanNode { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv.type_expanded, flag, position_type ], stream key: [] }
Fragment 61532 (Actor 739375,739374)
StreamTableScan { table: party_aum_mv, columns: [party_id, account_group_type, aum_market_value, fair_aum_market_value, aum_market_value_system_currency, fair_aum_market_value_system_currency] } { output: [ party_aum_mv.party_id, party_aum_mv.account_group_type, party_aum_mv.aum_market_value, party_aum_mv.fair_aum_market_value, party_aum_mv.aum_market_value_system_currency, party_aum_mv.fair_aum_market_value_system_currency ], stream key: [ party_aum_mv.party_id, party_aum_mv.account_group_type ] }
├── Upstream { output: [ party_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: [ party_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 61533 (Actor 739377,739376)
StreamTableScan { table: party_fee_totals_mv, columns: [party_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: [ party_fee_totals_mv.party_id, party_fee_totals_mv.account_group_type, party_fee_totals_mv.total_fees, party_fee_totals_mv.transactional_fees, party_fee_totals_mv.non_transactional_fees, party_fee_totals_mv.total_fees_system_currency, party_fee_totals_mv.transactional_fees_system_currency, party_fee_totals_mv.non_transactional_fees_system_currency ], stream key: [ party_fee_totals_mv.party_id, party_fee_totals_mv.account_group_type ] }
├── Upstream { output: [ party_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: [ party_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: [] }
Fragment 61534 (Actor 740045,740046)
StreamProject { exprs: [parties.id, parties.type, min(lifecycle_profiles.base_currency_code), null:Timestamptz, min(lifecycle_profiles.onboarding_date), null:Date, 'DRAFT':Varchar, 'none':Varchar, parties.display_name, null:Varchar, null:Varchar, party_individual.salutation, party_individual.suffix, party_individual.first_name, party_individual.last_name, min(customer_relationships.status_label_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.segment_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.base_currency_code), currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, 0:Int64, Coalesce(party_contact_counts_mv.contact_count, 0:Int64) as $expr30, 0:Int64, 0:Int64, 0:Int64, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, null:Int32, null:Int64, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, null:Varchar, null:Varchar, null:Varchar, 1:Int32] } { output: [ parties.id, parties.type, min(lifecycle_profiles.base_currency_code), null:Timestamptz, min(lifecycle_profiles.onboarding_date), null:Date, 'DRAFT':Varchar, 'none':Varchar, parties.display_name, null:Varchar, null:Varchar, party_individual.salutation, party_individual.suffix, party_individual.first_name, party_individual.last_name, min(customer_relationships.status_label_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.segment_id), labels_dm.name_en, labels_dm.name_ar, labels_dm.color, min(lifecycle_profiles.base_currency_code), currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol, 0:Int64, $expr30, 0:Int64, 0:Int64, 0:Int64, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, 0:Decimal, null:Int32, null:Int64, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
└── StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(lifecycle_profiles.base_currency_code) = currencies_dm.code, nested_loop: false } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, currencies_dm.code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
└── MergeExecutor { output: [ currencies_dm.code, currencies_dm.name_en, currencies_dm.name_ar, currencies_dm.symbol ], stream key: [ currencies_dm.code ] }
Fragment 61535 (Actor 739379,739378)
StreamLocalityProvider { locality_columns: [min(lifecycle_profiles.base_currency_code)] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
Fragment 61536 (Actor 737585,737584)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(lifecycle_profiles.segment_id) = labels_dm.label_id, nested_loop: false } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
└── MergeExecutor { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ labels_dm.label_id ] }
Fragment 61537 (Actor 739388,739387)
StreamLocalityProvider { locality_columns: [min(lifecycle_profiles.segment_id)] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(customer_relationships.status_label_id), parties.id ] }
Fragment 61538 (Actor 737574,737575)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(customer_relationships.status_label_id) = labels_dm.label_id, nested_loop: false } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count, labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ min(customer_relationships.status_label_id), parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ min(customer_relationships.status_label_id), parties.id ] }
└── MergeExecutor { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en, labels_dm.color ], stream key: [ labels_dm.label_id ] }
Fragment 61539 (Actor 739389,739390)
StreamLocalityProvider { locality_columns: [min(customer_relationships.status_label_id)] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ min(customer_relationships.status_label_id), parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ parties.id ] }
Fragment 61540 (Actor 739394,739393)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ parties.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_contact_counts_mv.party_id } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix, party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ party_contact_counts_mv.party_id ] }
Fragment 61541 (Actor 739398,739397)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ parties.id ] }
Fragment 61542 (Actor 739395,739396)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ parties.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_individual.party_id } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id) ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ party_individual.party_id ] }
Fragment 61543 (Actor 739400,739399)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id) ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id) ], stream key: [ parties.id ] }
Fragment 61544 (Actor 739402,739401)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id) ], stream key: [ parties.id ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = customer_relationships.party_id } { output: [ parties.id, parties.type, parties.display_name, customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id) ], stream key: [ parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id) ], stream key: [ customer_relationships.party_id ] }
Fragment 61545 (Actor 739403,739404)
StreamProject { exprs: [parties.id, parties.type, parties.display_name] } { output: [ parties.id, parties.type, parties.display_name ], stream key: [ parties.id ] }
└── StreamFilter { predicate: IsNull(parties.disabled_at) } { output: [ parties.id, parties.type, parties.display_name, parties.disabled_at ], stream key: [ parties.id ] }
└── StreamTableScan { table: parties, columns: [id, type, display_name, disabled_at] } { output: [ parties.id, parties.type, parties.display_name, parties.disabled_at ], stream key: [ parties.id ] }
├── Upstream { output: [ id, type, display_name, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ id, type, display_name, disabled_at ], stream key: [] }
Fragment 61546 (Actor 739405,739406)
StreamProject { exprs: [customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id)] } { output: [ customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id) ], stream key: [ customer_relationships.party_id ] }
└── StreamHashAgg { group_key: [customer_relationships.party_id], aggs: [min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), count] } { output: [ customer_relationships.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), count ], stream key: [ customer_relationships.party_id ] }
└── StreamLocalityProvider { locality_columns: [customer_relationships.party_id] } { output: [ customer_relationships.party_id, customer_relationships.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships.party_id, customer_relationships.id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ customer_relationships.party_id, customer_relationships.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships.id, customer_relationships.party_id, lifecycle_profiles.id ] }
Fragment 61547 (Actor 739408,739407)
StreamSyncLogStore { output: [ customer_relationships.party_id, customer_relationships.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships.id, customer_relationships.party_id, lifecycle_profiles.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: customer_relationships.id = lifecycle_profiles.customer_relationship_id } { output: [ customer_relationships.party_id, customer_relationships.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships.id, customer_relationships.party_id, lifecycle_profiles.id ] }
├── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, parties.id ], stream key: [ customer_relationships.id, customer_relationships.party_id ] }
└── MergeExecutor { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 61548 (Actor 739417,739418)
StreamLocalityProvider { locality_columns: [customer_relationships.id] } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, parties.id ], stream key: [ customer_relationships.id, customer_relationships.party_id ] }
└── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, parties.id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
Fragment 61549 (Actor 739419,739420)
StreamSyncLogStore { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, parties.id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
└── StreamHashJoin { type: Inner, predicate: customer_relationships.party_id = parties.id } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, parties.id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
├── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.party_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
└── MergeExecutor { output: [ parties.id ], stream key: [ parties.id ] }
Fragment 61550 (Actor 739435,739436)
StreamLocalityProvider { locality_columns: [customer_relationships.party_id] } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.party_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
└── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.party_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
Fragment 61551 (Actor 739433,739434)
StreamFilter { predicate: IsNull(party_active_customer_relationships_mv.party_id) } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.party_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
└── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.party_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
Fragment 61552 (Actor 739431,739432)
StreamSyncLogStore { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.party_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: customer_relationships.party_id = party_active_customer_relationships_mv.party_id } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, party_active_customer_relationships_mv.party_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
├── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61553 (Actor 739438,739437)
StreamLocalityProvider { locality_columns: [customer_relationships.party_id] } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id ], stream key: [ customer_relationships.party_id, customer_relationships.id ] }
└── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id ], stream key: [ customer_relationships.id ] }
Fragment 61554 (Actor 739441,739442)
StreamProject { exprs: [customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id] } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id ], stream key: [ customer_relationships.id ] }
└── StreamDynamicFilter { predicate: ($expr29 > now), output_watermarks: [[$expr29]], output: [customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, $expr29], cleaned_by_watermark: true } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, $expr29 ], stream key: [ customer_relationships.id ] }
├── StreamProject { exprs: [customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, AtTimeZone(Coalesce(customer_relationships.effective_to, '9999-12-31':Date)::Timestamp, 'UTC':Varchar) as $expr29] } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, $expr29 ], stream key: [ customer_relationships.id ] }
│ └── StreamDynamicFilter { predicate: ($expr28 <= now), output: [customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, customer_relationships.effective_to, $expr28], cleaned_by_watermark: true } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, customer_relationships.effective_to, $expr28 ], stream key: [ customer_relationships.id ] }
│ ├── StreamProject { exprs: [customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, customer_relationships.effective_to, AtTimeZone(customer_relationships.effective_from::Timestamp, 'UTC':Varchar) as $expr28] } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, customer_relationships.effective_to, $expr28 ], stream key: [ customer_relationships.id ] }
│ │ └── StreamFilter { predicate: (customer_relationships.type = 'CUSTOMER':Varchar) AND (customer_relationships.status = 'DRAFT':Varchar) AND IsNull(customer_relationships.disabled_at) } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, customer_relationships.effective_from, customer_relationships.effective_to, customer_relationships.type, customer_relationships.status, customer_relationships.disabled_at ], stream key: [ customer_relationships.id ] }
│ │ └── StreamTableScan { table: customer_relationships, columns: [id, party_id, status_label_id, effective_from, effective_to, type, status, disabled_at] } { output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.status_label_id, customer_relationships.effective_from, customer_relationships.effective_to, customer_relationships.type, customer_relationships.status, customer_relationships.disabled_at ], stream key: [ customer_relationships.id ] }
│ │ ├── Upstream { output: [ id, party_id, status_label_id, effective_from, effective_to, type, status, disabled_at ], stream key: [] }
│ │ └── BatchPlanNode { output: [ id, party_id, status_label_id, effective_from, effective_to, type, status, disabled_at ], stream key: [] }
│ └── MergeExecutor { output: [ now ], stream key: [] }
└── MergeExecutor { output: [ now ], stream key: [] }
Fragment 61555 (Actor 739443)
StreamNow { output: [ now ], stream key: [] }
Fragment 61556 (Actor 739444)
StreamNow { output: [ now ], stream key: [] }
Fragment 61557 (Actor 739238,739239)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv.party_id] } { output: [ party_active_customer_relationships_mv.party_id ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61558 (Actor 739241,739240)
StreamProject { exprs: [party_active_customer_relationships_mv.party_id] } { output: [ party_active_customer_relationships_mv.party_id ], stream key: [ party_active_customer_relationships_mv.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv.party_id ] }
Fragment 61559 (Actor 739450,739449)
StreamProject { exprs: [parties.id] } { output: [ parties.id ], stream key: [ parties.id ] }
└── StreamFilter { predicate: IsNull(parties.disabled_at) } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
└── StreamTableScan { table: parties, columns: [id, disabled_at] } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
├── Upstream { output: [ id, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ id, disabled_at ], stream key: [] }
Fragment 61560 (Actor 739451,739452)
StreamLocalityProvider { locality_columns: [lifecycle_profiles.customer_relationship_id] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.id ] }
Fragment 61561 (Actor 739453,739454)
StreamProject { exprs: [lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.id ] }
└── StreamFilter { predicate: IsNull(lifecycle_profiles.disabled_at) } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id, lifecycle_profiles.disabled_at ], stream key: [ lifecycle_profiles.id ] }
└── StreamTableScan { table: lifecycle_profiles, columns: [customer_relationship_id, base_currency_code, onboarding_date, segment_id, id, disabled_at] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, lifecycle_profiles.id, lifecycle_profiles.disabled_at ], stream key: [ lifecycle_profiles.id ] }
├── Upstream { output: [ customer_relationship_id, base_currency_code, onboarding_date, segment_id, id, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ customer_relationship_id, base_currency_code, onboarding_date, segment_id, id, disabled_at ], stream key: [] }
Fragment 61562 (Actor 739458,739457)
StreamTableScan { table: party_individual, columns: [party_id, salutation, first_name, last_name, suffix] } { output: [ party_individual.party_id, party_individual.salutation, party_individual.first_name, party_individual.last_name, party_individual.suffix ], stream key: [ party_individual.party_id ] }
├── Upstream { output: [ party_id, salutation, first_name, last_name, suffix ], stream key: [] }
└── BatchPlanNode { output: [ party_id, salutation, first_name, last_name, suffix ], stream key: [] }
Fragment 61563 (Actor 739459,739460)
StreamTableScan { table: party_contact_counts_mv, columns: [party_id, contact_count] } { output: [ party_contact_counts_mv.party_id, party_contact_counts_mv.contact_count ], stream key: [ party_contact_counts_mv.party_id ] }
├── Upstream { output: [ party_id, contact_count ], stream key: [] }
└── BatchPlanNode { output: [ party_id, contact_count ], stream key: [] }
Fragment 61564 (Actor 737560,737561)
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 61565 (Actor 737579,737578)
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 61566 (Actor 740040,740039)
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: [] }