clients_sink · explain

← cluster alinma_bff objects clients_sink explain
Overview Objects Graph History
sink · alinma_bff.clients_sink profiled over 5s
Job is idle — throughput ~0; structure shown.
Heat tree Operator graph
4 operators
Sink · alinma_bff.clients_sink
0% idle 2 actors
StreamScan · book_of_business_clients_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 61803 (Actor 739921,739922)
StreamSink { type: upsert, columns: [client_id, client_type, base_currency_code, created_at, onboarding_date, next_kyc_review_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, segment_name_en, segment_name_ar, segment_color, status_label_id, status_name_en, status_name_ar, status_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, market_value, fair_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, aum_value, fair_aum_value, aum_value_system_currency, fair_aum_value_system_currency, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency, reference_identifiers, book_of_business_clients_mv_next.client_to_account_groups_mv.account_group_id(hidden), book_of_business_clients_mv_next.client_to_account_groups_mv.$src(hidden), book_of_business_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded(hidden), book_of_business_clients_mv_next.position_snapshot_mv_next.flag(hidden)], downstream_pk: [book_of_business_clients_mv_next.client_id, book_of_business_clients_mv_next.account_group_type] }
├── output:
│   ┌── book_of_business_clients_mv_next.client_id
│   ├── book_of_business_clients_mv_next.client_type
│   ├── book_of_business_clients_mv_next.base_currency_code
│   ├── book_of_business_clients_mv_next.created_at
│   ├── book_of_business_clients_mv_next.onboarding_date
│   ├── book_of_business_clients_mv_next.next_kyc_review_date
│   ├── book_of_business_clients_mv_next.account_group_type
│   ├── book_of_business_clients_mv_next.display_name
│   ├── book_of_business_clients_mv_next.local_display_name
│   ├── book_of_business_clients_mv_next.preferred_name
│   ├── book_of_business_clients_mv_next.prefix
│   ├── book_of_business_clients_mv_next.suffix
│   ├── book_of_business_clients_mv_next.first_name
│   ├── book_of_business_clients_mv_next.last_name
│   ├── book_of_business_clients_mv_next.customer_identification_file
│   ├── book_of_business_clients_mv_next.segment_label_id
│   ├── book_of_business_clients_mv_next.segment_name_en
│   ├── book_of_business_clients_mv_next.segment_name_ar
│   ├── book_of_business_clients_mv_next.segment_color
│   ├── book_of_business_clients_mv_next.status_label_id
│   ├── book_of_business_clients_mv_next.status_name_en
│   ├── book_of_business_clients_mv_next.status_name_ar
│   ├── book_of_business_clients_mv_next.status_color
│   ├── book_of_business_clients_mv_next.currency_code
│   ├── book_of_business_clients_mv_next.currency_name_en
│   ├── book_of_business_clients_mv_next.currency_name_ar
│   ├── book_of_business_clients_mv_next.currency_symbol
│   ├── book_of_business_clients_mv_next.portfolio_count
│   ├── book_of_business_clients_mv_next.contact_count
│   ├── book_of_business_clients_mv_next.task_active_count
│   ├── book_of_business_clients_mv_next.task_high_priority_count
│   ├── book_of_business_clients_mv_next.market_value
│   ├── book_of_business_clients_mv_next.fair_value
│   ├── book_of_business_clients_mv_next.relationship_value
│   ├── book_of_business_clients_mv_next.fair_relationship_value
│   ├── book_of_business_clients_mv_next.market_value_system_currency
│   ├── book_of_business_clients_mv_next.fair_value_system_currency
│   ├── book_of_business_clients_mv_next.relationship_value_system_currency
│   ├── book_of_business_clients_mv_next.fair_relationship_value_system_currency
│   ├── book_of_business_clients_mv_next.aum_value
│   ├── book_of_business_clients_mv_next.fair_aum_value
│   ├── book_of_business_clients_mv_next.aum_value_system_currency
│   ├── book_of_business_clients_mv_next.fair_aum_value_system_currency
│   ├── book_of_business_clients_mv_next.total_fees
│   ├── book_of_business_clients_mv_next.transactional_fees
│   ├── book_of_business_clients_mv_next.non_transactional_fees
│   ├── book_of_business_clients_mv_next.total_fees_system_currency
│   ├── book_of_business_clients_mv_next.transactional_fees_system_currency
│   ├── book_of_business_clients_mv_next.non_transactional_fees_system_currency
│   ├── book_of_business_clients_mv_next.reference_identifiers
│   ├── book_of_business_clients_mv_next.client_to_account_groups_mv.account_group_id
│   ├── book_of_business_clients_mv_next.client_to_account_groups_mv.$src
│   ├── book_of_business_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded
│   └── book_of_business_clients_mv_next.position_snapshot_mv_next.flag
├── stream key: [ book_of_business_clients_mv_next.client_id, book_of_business_clients_mv_next.account_group_type, book_of_business_clients_mv_next.client_to_account_groups_mv.account_group_id, book_of_business_clients_mv_next.currency_code, book_of_business_clients_mv_next.status_label_id, book_of_business_clients_mv_next.segment_label_id, book_of_business_clients_mv_next.client_to_account_groups_mv.$src, book_of_business_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_clients_mv_next.position_snapshot_mv_next.flag ]
└── StreamTableScan { table: book_of_business_clients_mv_next, columns: [client_id, client_type, base_currency_code, created_at, onboarding_date, next_kyc_review_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, segment_name_en, segment_name_ar, segment_color, status_label_id, status_name_en, status_name_ar, status_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, market_value, fair_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, aum_value, fair_aum_value, aum_value_system_currency, fair_aum_value_system_currency, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency, reference_identifiers, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag] }
    ├── output:
    │   ┌── book_of_business_clients_mv_next.client_id
    │   ├── book_of_business_clients_mv_next.client_type
    │   ├── book_of_business_clients_mv_next.base_currency_code
    │   ├── book_of_business_clients_mv_next.created_at
    │   ├── book_of_business_clients_mv_next.onboarding_date
    │   ├── book_of_business_clients_mv_next.next_kyc_review_date
    │   ├── book_of_business_clients_mv_next.account_group_type
    │   ├── book_of_business_clients_mv_next.display_name
    │   ├── book_of_business_clients_mv_next.local_display_name
    │   ├── book_of_business_clients_mv_next.preferred_name
    │   ├── book_of_business_clients_mv_next.prefix
    │   ├── book_of_business_clients_mv_next.suffix
    │   ├── book_of_business_clients_mv_next.first_name
    │   ├── book_of_business_clients_mv_next.last_name
    │   ├── book_of_business_clients_mv_next.customer_identification_file
    │   ├── book_of_business_clients_mv_next.segment_label_id
    │   ├── book_of_business_clients_mv_next.segment_name_en
    │   ├── book_of_business_clients_mv_next.segment_name_ar
    │   ├── book_of_business_clients_mv_next.segment_color
    │   ├── book_of_business_clients_mv_next.status_label_id
    │   ├── book_of_business_clients_mv_next.status_name_en
    │   ├── book_of_business_clients_mv_next.status_name_ar
    │   ├── book_of_business_clients_mv_next.status_color
    │   ├── book_of_business_clients_mv_next.currency_code
    │   ├── book_of_business_clients_mv_next.currency_name_en
    │   ├── book_of_business_clients_mv_next.currency_name_ar
    │   ├── book_of_business_clients_mv_next.currency_symbol
    │   ├── book_of_business_clients_mv_next.portfolio_count
    │   ├── book_of_business_clients_mv_next.contact_count
    │   ├── book_of_business_clients_mv_next.task_active_count
    │   ├── book_of_business_clients_mv_next.task_high_priority_count
    │   ├── book_of_business_clients_mv_next.market_value
    │   ├── book_of_business_clients_mv_next.fair_value
    │   ├── book_of_business_clients_mv_next.relationship_value
    │   ├── book_of_business_clients_mv_next.fair_relationship_value
    │   ├── book_of_business_clients_mv_next.market_value_system_currency
    │   ├── book_of_business_clients_mv_next.fair_value_system_currency
    │   ├── book_of_business_clients_mv_next.relationship_value_system_currency
    │   ├── book_of_business_clients_mv_next.fair_relationship_value_system_currency
    │   ├── book_of_business_clients_mv_next.aum_value
    │   ├── book_of_business_clients_mv_next.fair_aum_value
    │   ├── book_of_business_clients_mv_next.aum_value_system_currency
    │   ├── book_of_business_clients_mv_next.fair_aum_value_system_currency
    │   ├── book_of_business_clients_mv_next.total_fees
    │   ├── book_of_business_clients_mv_next.transactional_fees
    │   ├── book_of_business_clients_mv_next.non_transactional_fees
    │   ├── book_of_business_clients_mv_next.total_fees_system_currency
    │   ├── book_of_business_clients_mv_next.transactional_fees_system_currency
    │   ├── book_of_business_clients_mv_next.non_transactional_fees_system_currency
    │   ├── book_of_business_clients_mv_next.reference_identifiers
    │   ├── book_of_business_clients_mv_next.client_to_account_groups_mv.account_group_id
    │   ├── book_of_business_clients_mv_next.client_to_account_groups_mv.$src
    │   ├── book_of_business_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded
    │   └── book_of_business_clients_mv_next.position_snapshot_mv_next.flag
    ├── stream key: [ book_of_business_clients_mv_next.client_id, book_of_business_clients_mv_next.account_group_type, book_of_business_clients_mv_next.client_to_account_groups_mv.account_group_id, book_of_business_clients_mv_next.currency_code, book_of_business_clients_mv_next.status_label_id, book_of_business_clients_mv_next.segment_label_id, book_of_business_clients_mv_next.client_to_account_groups_mv.$src, book_of_business_clients_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_clients_mv_next.position_snapshot_mv_next.flag ]
    ├── Upstream { output: [ client_id, client_type, base_currency_code, created_at, onboarding_date, next_kyc_review_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, segment_name_en, segment_name_ar, segment_color, status_label_id, status_name_en, status_name_ar, status_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, market_value, fair_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, aum_value, fair_aum_value, aum_value_system_currency, fair_aum_value_system_currency, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency, reference_identifiers, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, client_type, base_currency_code, created_at, onboarding_date, next_kyc_review_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, segment_name_en, segment_name_ar, segment_color, status_label_id, status_name_en, status_name_ar, status_color, currency_code, currency_name_en, currency_name_ar, currency_symbol, portfolio_count, contact_count, task_active_count, task_high_priority_count, market_value, fair_value, relationship_value, fair_relationship_value, market_value_system_currency, fair_value_system_currency, relationship_value_system_currency, fair_relationship_value_system_currency, aum_value, fair_aum_value, aum_value_system_currency, fair_aum_value_system_currency, total_fees, transactional_fees, non_transactional_fees, total_fees_system_currency, transactional_fees_system_currency, non_transactional_fees_system_currency, reference_identifiers, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
