RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster ai_hub_bff objects clients_sink explain
Overview Objects Graph History
sink · ai_hub_bff.clients_sink profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

4 operators
Sink · ai_hub_bff.clients_sink
0% idle 2 actors
StreamScan · book_of_business_clients_mv
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.
Sink · ai_hub_bff.clients_sink Sink ai_hub_bff.clients_sink idle · 2 actors StreamScan · book_of_business_clients_mv StreamScan book_of_business_client… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 15029 (Actor 158947,158946)
StreamSink { type: upsert, columns: [client_id, client_type, base_currency_code, created_at, onboarding_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, status_label_id, book_of_business_clients_mv.client_to_account_groups_mv.$src(hidden)], downstream_pk: [book_of_business_clients_mv.client_id, book_of_business_clients_mv.account_group_type] }
├── output:
│   ┌── book_of_business_clients_mv.client_id
│   ├── book_of_business_clients_mv.client_type
│   ├── book_of_business_clients_mv.base_currency_code
│   ├── book_of_business_clients_mv.created_at
│   ├── book_of_business_clients_mv.onboarding_date
│   ├── book_of_business_clients_mv.account_group_type
│   ├── book_of_business_clients_mv.display_name
│   ├── book_of_business_clients_mv.local_display_name
│   ├── book_of_business_clients_mv.preferred_name
│   ├── book_of_business_clients_mv.prefix
│   ├── book_of_business_clients_mv.suffix
│   ├── book_of_business_clients_mv.first_name
│   ├── book_of_business_clients_mv.last_name
│   ├── book_of_business_clients_mv.customer_identification_file
│   ├── book_of_business_clients_mv.segment_label_id
│   ├── book_of_business_clients_mv.status_label_id
│   └── book_of_business_clients_mv.client_to_account_groups_mv.$src
├── stream key: [ book_of_business_clients_mv.client_id, book_of_business_clients_mv.client_to_account_groups_mv.$src ]
└── StreamTableScan { table: book_of_business_clients_mv, columns: [client_id, client_type, base_currency_code, created_at, onboarding_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, status_label_id, client_to_account_groups_mv.$src] }
    ├── output:
    │   ┌── book_of_business_clients_mv.client_id
    │   ├── book_of_business_clients_mv.client_type
    │   ├── book_of_business_clients_mv.base_currency_code
    │   ├── book_of_business_clients_mv.created_at
    │   ├── book_of_business_clients_mv.onboarding_date
    │   ├── book_of_business_clients_mv.account_group_type
    │   ├── book_of_business_clients_mv.display_name
    │   ├── book_of_business_clients_mv.local_display_name
    │   ├── book_of_business_clients_mv.preferred_name
    │   ├── book_of_business_clients_mv.prefix
    │   ├── book_of_business_clients_mv.suffix
    │   ├── book_of_business_clients_mv.first_name
    │   ├── book_of_business_clients_mv.last_name
    │   ├── book_of_business_clients_mv.customer_identification_file
    │   ├── book_of_business_clients_mv.segment_label_id
    │   ├── book_of_business_clients_mv.status_label_id
    │   └── book_of_business_clients_mv.client_to_account_groups_mv.$src
    ├── stream key: [ book_of_business_clients_mv.client_id, book_of_business_clients_mv.client_to_account_groups_mv.$src ]
    ├── Upstream { output: [ client_id, client_type, base_currency_code, created_at, onboarding_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, status_label_id, client_to_account_groups_mv.$src ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, client_type, base_currency_code, created_at, onboarding_date, account_group_type, display_name, local_display_name, preferred_name, prefix, suffix, first_name, last_name, customer_identification_file, segment_label_id, status_label_id, client_to_account_groups_mv.$src ], stream key: [] }