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

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

Job is idle — throughput ~0; structure shown.

4 operators
Materialize · adib_rm.accounts_plain_mv
0% idle 2 actors
StreamScan · accounts_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.accounts_plain_mv Materialize adib_rm.accounts_plain_… idle · 2 actors StreamScan · accounts_dm StreamScan accounts_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 5310 (Actor 96711,96710)
StreamMaterialize { columns: [account_id, name, number, product_type_id, base_currency_code, is_restricted, opening_date, closing_date, created_at, disabled_at, status_label_id], stream_key: [account_id], pk_columns: [account_id], pk_conflict: NoCheck }
├── output:
│   ┌── accounts_dm.account_id
│   ├── accounts_dm.name
│   ├── accounts_dm.number
│   ├── accounts_dm.product_type_id
│   ├── accounts_dm.base_currency_code
│   ├── accounts_dm.is_restricted
│   ├── accounts_dm.opening_date
│   ├── accounts_dm.closing_date
│   ├── accounts_dm.created_at
│   ├── accounts_dm.disabled_at
│   └── accounts_dm.status_label_id
├── stream key: [ accounts_dm.account_id ]
└── StreamTableScan { table: accounts_dm, columns: [account_id, name, number, product_type_id, base_currency_code, is_restricted, opening_date, closing_date, created_at, disabled_at, status_label_id] }
    ├── output:
    │   ┌── accounts_dm.account_id
    │   ├── accounts_dm.name
    │   ├── accounts_dm.number
    │   ├── accounts_dm.product_type_id
    │   ├── accounts_dm.base_currency_code
    │   ├── accounts_dm.is_restricted
    │   ├── accounts_dm.opening_date
    │   ├── accounts_dm.closing_date
    │   ├── accounts_dm.created_at
    │   ├── accounts_dm.disabled_at
    │   └── accounts_dm.status_label_id
    ├── stream key: [ accounts_dm.account_id ]
    ├── Upstream { output: [ account_id, name, number, product_type_id, base_currency_code, is_restricted, opening_date, closing_date, created_at, disabled_at, status_label_id ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, name, number, product_type_id, base_currency_code, is_restricted, opening_date, closing_date, created_at, disabled_at, status_label_id ], stream key: [] }