RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local

← cluster adib_rm objects portfolios_plain_mv explain
Overview Objects Graph History
materialized view · adib_rm.portfolios_plain_mv profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

4 operators
Materialize · adib_rm.portfolios_plain_mv
0% idle 2 actors
StreamScan · portfolios_dm
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.
Materialize · adib_rm.portfolios_plain_mv Materialize adib_rm.portfolios_plai… idle · 2 actors StreamScan · portfolios_dm StreamScan portfolios_dm 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 2378 (Actor 100192,100193)
StreamMaterialize { columns: [portfolio_id, name, number, base_currency_code, service_type_id, status_label_id, opening_date, closing_date, created_at, disabled_at], stream_key: [portfolio_id], pk_columns: [portfolio_id], pk_conflict: NoCheck }
├── output:
│   ┌── portfolios_dm.portfolio_id
│   ├── portfolios_dm.name
│   ├── portfolios_dm.number
│   ├── portfolios_dm.base_currency_code
│   ├── portfolios_dm.service_type_id
│   ├── portfolios_dm.status_label_id
│   ├── portfolios_dm.opening_date
│   ├── portfolios_dm.closing_date
│   ├── portfolios_dm.created_at
│   └── portfolios_dm.disabled_at
├── stream key: [ portfolios_dm.portfolio_id ]
└── StreamTableScan { table: portfolios_dm, columns: [portfolio_id, name, number, base_currency_code, service_type_id, status_label_id, opening_date, closing_date, created_at, disabled_at] }
    ├── output:
    │   ┌── portfolios_dm.portfolio_id
    │   ├── portfolios_dm.name
    │   ├── portfolios_dm.number
    │   ├── portfolios_dm.base_currency_code
    │   ├── portfolios_dm.service_type_id
    │   ├── portfolios_dm.status_label_id
    │   ├── portfolios_dm.opening_date
    │   ├── portfolios_dm.closing_date
    │   ├── portfolios_dm.created_at
    │   └── portfolios_dm.disabled_at
    ├── stream key: [ portfolios_dm.portfolio_id ]
    ├── Upstream { output: [ portfolio_id, name, number, base_currency_code, service_type_id, status_label_id, opening_date, closing_date, created_at, disabled_at ], stream key: [] }
    └── BatchPlanNode { output: [ portfolio_id, name, number, base_currency_code, service_type_id, status_label_id, opening_date, closing_date, created_at, disabled_at ], stream key: [] }