Fragment 63971 (Actor 745336,745337)
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_next.status_label_id)(hidden), position_snapshot_mv_next.holding_values_latest_mv_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.status_label_id), position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, $src ]
├── stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.status_label_id), position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, $src ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.status_label_id), position_snapshot_mv_next.holding_values_latest_mv_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.status_label_id), parties.id ] }
Fragment 63972 (Actor 745341,745340)
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_next.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_next.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_next.aum_market_value, 0:Decimal) as $expr18
├─Coalesce(party_aum_mv_next.fair_aum_market_value, 0:Decimal) as $expr19
├─Coalesce(party_aum_mv_next.aum_market_value_system_currency, 0:Decimal) as $expr20
├─Coalesce(party_aum_mv_next.fair_aum_market_value_system_currency, 0:Decimal) as $expr21
├─Coalesce(party_fee_totals_mv_next.total_fees, 0:Decimal) as $expr22
├─Coalesce(party_fee_totals_mv_next.transactional_fees, 0:Decimal) as $expr23
├─Coalesce(party_fee_totals_mv_next.non_transactional_fees, 0:Decimal) as $expr24
├─Coalesce(party_fee_totals_mv_next.total_fees_system_currency, 0:Decimal) as $expr25
├─Coalesce(party_fee_totals_mv_next.transactional_fees_system_currency, 0:Decimal) as $expr26
├─Coalesce(party_fee_totals_mv_next.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_next.status_label_id)
├─position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.status_label_id), position_snapshot_mv_next.holding_values_latest_mv_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, party_fee_totals_mv_next.total_fees, party_fee_totals_mv_next.transactional_fees, party_fee_totals_mv_next.non_transactional_fees, party_fee_totals_mv_next.total_fees_system_currency, party_fee_totals_mv_next.transactional_fees_system_currency, party_fee_totals_mv_next.non_transactional_fees_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_fee_totals_mv_next.party_id, party_fee_totals_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
Fragment 63973 (Actor 745338,745339)
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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, party_fee_totals_mv_next.total_fees, party_fee_totals_mv_next.transactional_fees, party_fee_totals_mv_next.non_transactional_fees, party_fee_totals_mv_next.total_fees_system_currency, party_fee_totals_mv_next.transactional_fees_system_currency, party_fee_totals_mv_next.non_transactional_fees_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_fee_totals_mv_next.party_id, party_fee_totals_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_fee_totals_mv_next.party_id AND 'all':Varchar = party_fee_totals_mv_next.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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, party_fee_totals_mv_next.total_fees, party_fee_totals_mv_next.transactional_fees, party_fee_totals_mv_next.non_transactional_fees, party_fee_totals_mv_next.total_fees_system_currency, party_fee_totals_mv_next.transactional_fees_system_currency, party_fee_totals_mv_next.non_transactional_fees_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_fee_totals_mv_next.party_id, party_fee_totals_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_aum_mv_next.party_id, party_aum_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ party_fee_totals_mv_next.party_id, party_fee_totals_mv_next.account_group_type, party_fee_totals_mv_next.total_fees, party_fee_totals_mv_next.transactional_fees, party_fee_totals_mv_next.non_transactional_fees, party_fee_totals_mv_next.total_fees_system_currency, party_fee_totals_mv_next.transactional_fees_system_currency, party_fee_totals_mv_next.non_transactional_fees_system_currency ], stream key: [ party_fee_totals_mv_next.party_id, party_fee_totals_mv_next.account_group_type ] }
Fragment 63974 (Actor 745345,745344)
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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_aum_mv_next.party_id, party_aum_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_aum_mv_next.party_id, party_aum_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
Fragment 63975 (Actor 745343,745342)
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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_aum_mv_next.party_id, party_aum_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_aum_mv_next.party_id AND 'all':Varchar = party_aum_mv_next.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_next.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_next.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_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency, $expr1, $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_aum_mv_next.party_id, party_aum_mv_next.account_group_type ], stream key: [ parties.id, 'all':Varchar, $expr1, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ party_aum_mv_next.party_id, party_aum_mv_next.account_group_type, party_aum_mv_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency ], stream key: [ party_aum_mv_next.party_id, party_aum_mv_next.account_group_type ] }
Fragment 63976 (Actor 745347,745346)
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_next.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_next.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_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
Fragment 63977 (Actor 745349,745348)
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_next.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_next.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_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.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_next.status_label_id), $src, position_snapshot_mv_next.holding_values_latest_mv_next.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_next.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_next.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_next.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_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
Fragment 63978 (Actor 746936,746937)
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_next.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_next.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_next.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_next.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_next.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_next.status_label_id), $src ] }
Fragment 63979 (Actor 746938,746939)
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_next.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_next.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_next.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_next.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_next.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_next.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_next.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_next.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_next.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 63980 (Actor 746942,746943)
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_next.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_next.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_next.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_next.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_next.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_next.status_label_id), $src ] }
Fragment 63981 (Actor 746940,746941)
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_next.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_next.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_next.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_next.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_next.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_next.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_next.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_next.portfolio_count, $src, party_portfolio_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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 63982 (Actor 746947,746946)
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_next.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_next.portfolio_count, $src, party_portfolio_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.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_next.portfolio_count, $src, party_portfolio_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src ] }
Fragment 63983 (Actor 746944,746945)
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_next.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_next.portfolio_count, $src, party_portfolio_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_portfolio_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_next.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_next.portfolio_count, $src, party_portfolio_counts_mv_next.party_id ], stream key: [ parties.id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.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_next.status_label_id), $src ] }
└── MergeExecutor { output: [ party_portfolio_counts_mv_next.party_id, party_portfolio_counts_mv_next.portfolio_count ], stream key: [ party_portfolio_counts_mv_next.party_id ] }
Fragment 63984 (Actor 745450,745449)
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_next.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_next.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_next.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_next.status_label_id), parties.id, $src ] }
Fragment 63985 (Actor 741737,741738)
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_next.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_next.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_next.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_next.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 63986 (Actor 745691,745690)
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_next.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_next.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_next.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_next.status_label_id), parties.id, $src ] }
Fragment 63987 (Actor 742288,742287)
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_next.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_next.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_next.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_next.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 63988 (Actor 745811,745810)
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_next.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_next.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_next.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_next.status_label_id), parties.id, $src ] }
Fragment 63989 (Actor 742286,742285)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(customer_relationships_next.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_next.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_next.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_next.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_next.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 63990 (Actor 745937,745936)
StreamLocalityProvider { locality_columns: [min(customer_relationships_next.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_next.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_next.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_next.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 63991 (Actor 746948,746949)
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_next.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_next.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_next.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv_next.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 63992 (Actor 746952,746953)
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_next.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv_next.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_next.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv_next.party_id, $src ], stream key: [ parties.id, $src ] }
Fragment 63993 (Actor 746951,746950)
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_next.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv_next.party_id, $src ], stream key: [ parties.id, $src ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = party_active_customer_relationships_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_next.status_label_id), 'ACTIVE':Varchar, $expr1, 'all':Varchar, party_active_customer_relationships_mv_next.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_next.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, $src ] }
Fragment 63994 (Actor 746956,746957)
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_next.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv_next.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_next.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv_next.party_id ], stream key: [ parties.id ] }
Fragment 63995 (Actor 746955,746954)
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_next.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv_next.party_id ], stream key: [ parties.id ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = party_active_customer_relationships_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_next.status_label_id), 'ACTIVE':Varchar, party_active_customer_relationships_mv_next.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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 63996 (Actor 745975,745974)
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 63997 (Actor 746965,746964)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.party_id] } { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 63998 (Actor 746960,746961)
StreamNoOp { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 63999 (Actor 746962,746963)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar] } { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── StreamHashAgg { group_key: [party_active_customer_relationships_mv_next.party_id], aggs: [min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), count] } { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), count ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.party_id] } { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 64000 (Actor 746983,746982)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 64001 (Actor 746981,746980)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 64002 (Actor 746979,746978)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 64003 (Actor 746977,746976)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 64004 (Actor 746986,746987)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
Fragment 64005 (Actor 746985,746984)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: party_active_customer_relationships_mv_next.customer_relationship_id = lifecycle_profiles.customer_relationship_id } { output: [ party_active_customer_relationships_mv_next.party_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.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 64006 (Actor 745988,745989)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.customer_relationship_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
Fragment 64007 (Actor 745981,745980)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
Fragment 64008 (Actor 745978,745979)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
Fragment 64009 (Actor 745986,745987)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
Fragment 64010 (Actor 745977,745976)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
Fragment 64011 (Actor 745983,745982)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
Fragment 64012 (Actor 745984,745985)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── StreamHashJoin { type: Inner, predicate: party_active_customer_relationships_mv_next.customer_relationship_id = customer_relationships_next.id } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, customer_relationships_next.status_label_id, customer_relationships_next.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
└── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.status_label_id ], stream key: [ customer_relationships_next.id ] }
Fragment 64013 (Actor 746122,746121)
StreamTableScan { table: party_active_customer_relationships_mv_next, columns: [party_id, customer_relationship_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
├── Upstream { output: [ party_id, customer_relationship_id ], stream key: [] }
└── BatchPlanNode { output: [ party_id, customer_relationship_id ], stream key: [] }
Fragment 64014 (Actor 746123,746124)
StreamTableScan { table: customer_relationships_next, columns: [id, status_label_id] } { output: [ customer_relationships_next.id, customer_relationships_next.status_label_id ], stream key: [ customer_relationships_next.id ] }
├── Upstream { output: [ id, status_label_id ], stream key: [] }
└── BatchPlanNode { output: [ id, status_label_id ], stream key: [] }
Fragment 64015 (Actor 742266,742267)
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 64016 (Actor 742324,742325)
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 64017 (Actor 742535,742536)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.party_id] } { output: [ party_active_customer_relationships_mv_next.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, $src ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, $src ] }
Fragment 64018 (Actor 742622,742621)
StreamUnion { all: true } { output: [ party_active_customer_relationships_mv_next.party_id, $expr1, 'all':Varchar, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, $src ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, $expr1, 'all':Varchar, 0:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, $expr2, 'restricted':Varchar, 1:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, $expr3, 'un_restricted':Varchar, 2:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, $expr4, 'none':Varchar, 3:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64019 (Actor 746974,746975)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv_next.party_id, 'all':Varchar)::Bytea)) as $expr1, 'all':Varchar, 0:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, $expr1, 'all':Varchar, 0:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64020 (Actor 746971,746970)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv_next.party_id, 'restricted':Varchar)::Bytea)) as $expr2, 'restricted':Varchar, 1:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, $expr2, 'restricted':Varchar, 1:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64021 (Actor 746968,746969)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv_next.party_id, 'un_restricted':Varchar)::Bytea)) as $expr3, 'un_restricted':Varchar, 2:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, $expr3, 'un_restricted':Varchar, 2:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64022 (Actor 746959,746958)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_active_customer_relationships_mv_next.party_id, 'none':Varchar)::Bytea)) as $expr4, 'none':Varchar, 3:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, $expr4, 'none':Varchar, 3:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64023 (Actor 742785,742786)
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 64024 (Actor 742276,742275)
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 64025 (Actor 742273,742274)
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 64026 (Actor 741755,741756)
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 64027 (Actor 743654,743653)
StreamTableScan { table: party_portfolio_counts_mv_next, columns: [party_id, portfolio_count] } { output: [ party_portfolio_counts_mv_next.party_id, party_portfolio_counts_mv_next.portfolio_count ], stream key: [ party_portfolio_counts_mv_next.party_id ] }
├── Upstream { output: [ party_id, portfolio_count ], stream key: [] }
└── BatchPlanNode { output: [ party_id, portfolio_count ], stream key: [] }
Fragment 64028 (Actor 746990,746991)
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 64029 (Actor 746993,746992)
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 64030 (Actor 746994,746995)
StreamLocalityProvider { locality_columns: [position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── MergeExecutor { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
Fragment 64031 (Actor 746996,746997)
StreamProject { exprs: [position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamFilter { predicate: (position_snapshot_mv_next.position_type = 'POSITION':Varchar) } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamTableScan { table: position_snapshot_mv_next, columns: [account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.fair_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.fair_value_system_currency, position_snapshot_mv_next.relationship_value, position_snapshot_mv_next.fair_relationship_value, position_snapshot_mv_next.relationship_value_system_currency, position_snapshot_mv_next.fair_relationship_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
├── Upstream { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }
└── BatchPlanNode { output: [ account_group_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, relationship_value, fair_relationship_value, relationship_value_system_currency, fair_relationship_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }
Fragment 64032 (Actor 746998,746999)
StreamTableScan { table: party_aum_mv_next, 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_next.party_id, party_aum_mv_next.account_group_type, party_aum_mv_next.aum_market_value, party_aum_mv_next.fair_aum_market_value, party_aum_mv_next.aum_market_value_system_currency, party_aum_mv_next.fair_aum_market_value_system_currency ], stream key: [ party_aum_mv_next.party_id, party_aum_mv_next.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 64033 (Actor 747001,747000)
StreamTableScan { table: party_fee_totals_mv_next, 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_next.party_id, party_fee_totals_mv_next.account_group_type, party_fee_totals_mv_next.total_fees, party_fee_totals_mv_next.transactional_fees, party_fee_totals_mv_next.non_transactional_fees, party_fee_totals_mv_next.total_fees_system_currency, party_fee_totals_mv_next.transactional_fees_system_currency, party_fee_totals_mv_next.non_transactional_fees_system_currency ], stream key: [ party_fee_totals_mv_next.party_id, party_fee_totals_mv_next.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 64034 (Actor 741750,741749)
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_next.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_next.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_next.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_next.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_next.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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.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 64035 (Actor 746989,746988)
StreamLocalityProvider { locality_columns: [min(lifecycle_profiles.base_currency_code)] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
Fragment 64036 (Actor 742271,742272)
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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.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 64037 (Actor 742033,742034)
StreamLocalityProvider { locality_columns: [min(lifecycle_profiles.segment_id)] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
Fragment 64038 (Actor 742299,742300)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: min(customer_relationships_next.status_label_id) = labels_dm.label_id, nested_loop: false } { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.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 64039 (Actor 742136,742137)
StreamLocalityProvider { locality_columns: [min(customer_relationships_next.status_label_id)] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.status_label_id), parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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 64040 (Actor 747003,747002)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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 64041 (Actor 747006,747007)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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 64042 (Actor 747004,747005)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.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 64043 (Actor 747009,747008)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id) ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id) ], stream key: [ parties.id ] }
Fragment 64044 (Actor 747011,747010)
StreamSyncLogStore { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id) ], stream key: [ parties.id ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = customer_relationships_next.party_id } { output: [ parties.id, parties.type, parties.display_name, customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id) ], stream key: [ parties.id ] }
├── MergeExecutor { output: [ parties.id, parties.type, parties.display_name ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id) ], stream key: [ customer_relationships_next.party_id ] }
Fragment 64045 (Actor 742883,742882)
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 64046 (Actor 747012,747013)
StreamProject { exprs: [customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id)] } { output: [ customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id) ], stream key: [ customer_relationships_next.party_id ] }
└── StreamHashAgg { group_key: [customer_relationships_next.party_id], aggs: [min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), count] } { output: [ customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), count ], stream key: [ customer_relationships_next.party_id ] }
└── StreamLocalityProvider { locality_columns: [customer_relationships_next.party_id] } { output: [ customer_relationships_next.party_id, customer_relationships_next.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ customer_relationships_next.party_id, customer_relationships_next.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships_next.id, customer_relationships_next.party_id, lifecycle_profiles.id ] }
Fragment 64047 (Actor 747014,747015)
StreamSyncLogStore { output: [ customer_relationships_next.party_id, customer_relationships_next.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships_next.id, customer_relationships_next.party_id, lifecycle_profiles.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: customer_relationships_next.id = lifecycle_profiles.customer_relationship_id } { output: [ customer_relationships_next.party_id, customer_relationships_next.status_label_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.onboarding_date, lifecycle_profiles.segment_id, customer_relationships_next.id, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ customer_relationships_next.id, customer_relationships_next.party_id, lifecycle_profiles.id ] }
├── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, parties.id ], stream key: [ customer_relationships_next.id, customer_relationships_next.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 64048 (Actor 747016,747017)
StreamLocalityProvider { locality_columns: [customer_relationships_next.id] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, parties.id ], stream key: [ customer_relationships_next.id, customer_relationships_next.party_id ] }
└── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, parties.id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
Fragment 64049 (Actor 747018,747019)
StreamSyncLogStore { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, parties.id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
└── StreamHashJoin { type: Inner, predicate: customer_relationships_next.party_id = parties.id } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, parties.id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
├── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.party_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
└── MergeExecutor { output: [ parties.id ], stream key: [ parties.id ] }
Fragment 64050 (Actor 742939,742940)
StreamLocalityProvider { locality_columns: [customer_relationships_next.party_id] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.party_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
└── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.party_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
Fragment 64051 (Actor 742944,742943)
StreamFilter { predicate: IsNull(party_active_customer_relationships_mv_next.party_id) } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.party_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
└── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.party_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
Fragment 64052 (Actor 742942,742941)
StreamSyncLogStore { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.party_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: customer_relationships_next.party_id = party_active_customer_relationships_mv_next.party_id } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, party_active_customer_relationships_mv_next.party_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
├── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64053 (Actor 743538,743537)
StreamLocalityProvider { locality_columns: [customer_relationships_next.party_id] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id ], stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ] }
└── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id ], stream key: [ customer_relationships_next.id ] }
Fragment 64054 (Actor 743540,743539)
StreamProject { exprs: [customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id ], stream key: [ customer_relationships_next.id ] }
└── StreamDynamicFilter { predicate: ($expr29 > now), output_watermarks: [[$expr29]], output: [customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, $expr29], cleaned_by_watermark: true } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, $expr29 ], stream key: [ customer_relationships_next.id ] }
├── StreamProject { exprs: [customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, AtTimeZone(Coalesce(customer_relationships_next.effective_to, '9999-12-31':Date)::Timestamp, 'UTC':Varchar) as $expr29] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, $expr29 ], stream key: [ customer_relationships_next.id ] }
│ └── StreamDynamicFilter { predicate: ($expr28 <= now), output: [customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, customer_relationships_next.effective_to, $expr28], cleaned_by_watermark: true } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, customer_relationships_next.effective_to, $expr28 ], stream key: [ customer_relationships_next.id ] }
│ ├── StreamProject { exprs: [customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, customer_relationships_next.effective_to, AtTimeZone(customer_relationships_next.effective_from::Timestamp, 'UTC':Varchar) as $expr28] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, customer_relationships_next.effective_to, $expr28 ], stream key: [ customer_relationships_next.id ] }
│ │ └── StreamFilter { predicate: (customer_relationships_next.type = 'CUSTOMER':Varchar) AND (customer_relationships_next.status = 'DRAFT':Varchar) AND IsNull(customer_relationships_next.disabled_at) } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, customer_relationships_next.effective_from, customer_relationships_next.effective_to, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
│ │ └── StreamTableScan { table: customer_relationships_next, columns: [id, party_id, status_label_id, effective_from, effective_to, type, status, disabled_at] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.status_label_id, customer_relationships_next.effective_from, customer_relationships_next.effective_to, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.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 64055 (Actor 743543)
StreamNow { output: [ now ], stream key: [] }
Fragment 64056 (Actor 743544)
StreamNow { output: [ now ], stream key: [] }
Fragment 64057 (Actor 746966,746967)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.party_id] } { output: [ party_active_customer_relationships_mv_next.party_id ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64058 (Actor 746972,746973)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id] } { output: [ party_active_customer_relationships_mv_next.party_id ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, min(lifecycle_profiles.base_currency_code), min(lifecycle_profiles.onboarding_date), min(lifecycle_profiles.segment_id), min(customer_relationships_next.status_label_id), 'ACTIVE':Varchar ], stream key: [ party_active_customer_relationships_mv_next.party_id ] }
Fragment 64059 (Actor 743620,743619)
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 64060 (Actor 747021,747020)
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 64061 (Actor 747023,747022)
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 64062 (Actor 747025,747024)
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 64063 (Actor 747026,747027)
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 64064 (Actor 742296,742295)
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 64065 (Actor 742301,742302)
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 64066 (Actor 741747,741748)
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: [] }