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

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

Job is idle — throughput ~0; structure shown.

4 operators
Materialize · adib_rm.holding_breaks_mv
0% idle 2 actors
StreamScan · ibor_holding_breaks
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.holding_breaks_mv Materialize adib_rm.holding_breaks_… idle · 2 actors StreamScan · ibor_holding_breaks StreamScan ibor_holding_breaks 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 25026 (Actor 119875,119874)
StreamMaterialize { columns: [break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by], stream_key: [break_id], pk_columns: [break_id], pk_conflict: NoCheck }
├── output:
│   ┌── ibor_holding_breaks.break_id
│   ├── ibor_holding_breaks.source_system
│   ├── ibor_holding_breaks.business_date
│   ├── ibor_holding_breaks.break_type
│   ├── ibor_holding_breaks.severity
│   ├── ibor_holding_breaks.status
│   ├── ibor_holding_breaks.account_id
│   ├── ibor_holding_breaks.asset_id
│   ├── ibor_holding_breaks.order_id
│   ├── ibor_holding_breaks.file_id
│   ├── ibor_holding_breaks.row_ordinal
│   ├── ibor_holding_breaks.expected
│   ├── ibor_holding_breaks.actual
│   ├── ibor_holding_breaks.detected_at
│   ├── ibor_holding_breaks.resolved_at
│   ├── ibor_holding_breaks.resolution_note
│   └── ibor_holding_breaks.resolved_by
├── stream key: [ ibor_holding_breaks.break_id ]
└── StreamTableScan { table: ibor_holding_breaks, columns: [break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by] }
    ├── output:
    │   ┌── ibor_holding_breaks.break_id
    │   ├── ibor_holding_breaks.source_system
    │   ├── ibor_holding_breaks.business_date
    │   ├── ibor_holding_breaks.break_type
    │   ├── ibor_holding_breaks.severity
    │   ├── ibor_holding_breaks.status
    │   ├── ibor_holding_breaks.account_id
    │   ├── ibor_holding_breaks.asset_id
    │   ├── ibor_holding_breaks.order_id
    │   ├── ibor_holding_breaks.file_id
    │   ├── ibor_holding_breaks.row_ordinal
    │   ├── ibor_holding_breaks.expected
    │   ├── ibor_holding_breaks.actual
    │   ├── ibor_holding_breaks.detected_at
    │   ├── ibor_holding_breaks.resolved_at
    │   ├── ibor_holding_breaks.resolution_note
    │   └── ibor_holding_breaks.resolved_by
    ├── stream key: [ ibor_holding_breaks.break_id ]
    ├── Upstream { output: [ break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by ], stream key: [] }
    └── BatchPlanNode { output: [ break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by ], stream key: [] }