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

← cluster olap objects ibor_holding_candidates explain
Overview Objects Graph History
table · olap.ibor_holding_candidates profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

14 operators
Materialize · olap.ibor_holding_candidates
0% idle 2 actors
Union
0% idle 2 actors
UpstreamSinkUnion
1% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Dml
0% idle 2 actors
Source
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamCdcScan · olap
0% idle 1 actor
Merge
— — 1 actor
Exchange
0% idle 0 actors
CdcFilter
0% idle 1 actor
Merge
— — 1 actor
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · olap.ibor_holding_candidates Materialize olap.ibor_holding_candi… idle · 2 actors Union Union idle · 2 actors UpstreamSinkUnion UpstreamSinkUnion idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Dml Dml idle · 2 actors Source Source idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamCdcScan · olap StreamCdcScan olap idle · 1 actor Merge Merge — · 1 actor Exchange Exchange idle · 0 actors CdcFilter CdcFilter idle · 1 actor Merge Merge — · 1 actor
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 22067 (Actor 99336,99335)
StreamMaterialize { columns: [candidate_id, source_system, source_account_ref, source_asset_ref, account_id, asset_id, business_date, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at], stream_key: [candidate_id], pk_columns: [candidate_id], pk_conflict: Overwrite }
├── output:
│   ┌── olap.ibor_holding_candidates.candidate_id
│   ├── olap.ibor_holding_candidates.source_system
│   ├── olap.ibor_holding_candidates.source_account_ref
│   ├── olap.ibor_holding_candidates.source_asset_ref
│   ├── olap.ibor_holding_candidates.account_id
│   ├── olap.ibor_holding_candidates.asset_id
│   ├── olap.ibor_holding_candidates.business_date
│   ├── olap.ibor_holding_candidates.quantity
│   ├── olap.ibor_holding_candidates.market_value
│   ├── olap.ibor_holding_candidates.market_value_currency
│   ├── olap.ibor_holding_candidates.average_cost_per_unit
│   ├── olap.ibor_holding_candidates.source_revision
│   ├── olap.ibor_holding_candidates.superseded_revision
│   ├── olap.ibor_holding_candidates.reconciled_revision
│   └── olap.ibor_holding_candidates.updated_at
├── stream key: [ olap.ibor_holding_candidates.candidate_id ]
└── StreamUnion { all: true }
    ├── output:
    │   ┌── olap.ibor_holding_candidates.candidate_id
    │   ├── olap.ibor_holding_candidates.source_system
    │   ├── olap.ibor_holding_candidates.source_account_ref
    │   ├── olap.ibor_holding_candidates.source_asset_ref
    │   ├── olap.ibor_holding_candidates.account_id
    │   ├── olap.ibor_holding_candidates.asset_id
    │   ├── olap.ibor_holding_candidates.business_date
    │   ├── olap.ibor_holding_candidates.quantity
    │   ├── olap.ibor_holding_candidates.market_value
    │   ├── olap.ibor_holding_candidates.market_value_currency
    │   ├── olap.ibor_holding_candidates.average_cost_per_unit
    │   ├── olap.ibor_holding_candidates.source_revision
    │   ├── olap.ibor_holding_candidates.superseded_revision
    │   ├── olap.ibor_holding_candidates.reconciled_revision
    │   └── olap.ibor_holding_candidates.updated_at
    ├── stream key: []
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── olap.ibor_holding_candidates.candidate_id
    │   │   ├── olap.ibor_holding_candidates.source_system
    │   │   ├── olap.ibor_holding_candidates.source_account_ref
    │   │   ├── olap.ibor_holding_candidates.source_asset_ref
    │   │   ├── olap.ibor_holding_candidates.account_id
    │   │   ├── olap.ibor_holding_candidates.asset_id
    │   │   ├── olap.ibor_holding_candidates.business_date
    │   │   ├── olap.ibor_holding_candidates.quantity
    │   │   ├── olap.ibor_holding_candidates.market_value
    │   │   ├── olap.ibor_holding_candidates.market_value_currency
    │   │   ├── olap.ibor_holding_candidates.average_cost_per_unit
    │   │   ├── olap.ibor_holding_candidates.source_revision
    │   │   ├── olap.ibor_holding_candidates.superseded_revision
    │   │   ├── olap.ibor_holding_candidates.reconciled_revision
    │   │   └── olap.ibor_holding_candidates.updated_at
    │   └── stream key: [ olap.ibor_holding_candidates.candidate_id ]
    ├── MergeExecutor { output: [ candidate_id, source_system, source_account_ref, source_asset_ref, account_id, asset_id, business_date, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at ], stream key: [] }
    └── StreamUpstreamSinkUnion { output: [ candidate_id, source_system, source_account_ref, source_asset_ref, account_id, asset_id, business_date, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at ], stream key: [] }

Fragment 22068 (Actor 99339)
StreamCdcTableScan { table: olap.ibor_holding_candidates, columns: [candidate_id, source_system, source_account_ref, source_asset_ref, account_id, asset_id, business_date, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at] }
├── output:
│   ┌── olap.ibor_holding_candidates.candidate_id
│   ├── olap.ibor_holding_candidates.source_system
│   ├── olap.ibor_holding_candidates.source_account_ref
│   ├── olap.ibor_holding_candidates.source_asset_ref
│   ├── olap.ibor_holding_candidates.account_id
│   ├── olap.ibor_holding_candidates.asset_id
│   ├── olap.ibor_holding_candidates.business_date
│   ├── olap.ibor_holding_candidates.quantity
│   ├── olap.ibor_holding_candidates.market_value
│   ├── olap.ibor_holding_candidates.market_value_currency
│   ├── olap.ibor_holding_candidates.average_cost_per_unit
│   ├── olap.ibor_holding_candidates.source_revision
│   ├── olap.ibor_holding_candidates.superseded_revision
│   ├── olap.ibor_holding_candidates.reconciled_revision
│   └── olap.ibor_holding_candidates.updated_at
├── stream key: [ olap.ibor_holding_candidates.candidate_id ]
└── MergeExecutor { output: [ payload, _rw_offset, _rw_table_name ], stream key: [] }

Fragment 22069 (Actor 100123)
StreamCdcFilter { output: [ payload, _rw_offset, _rw_table_name ], stream key: [] }
└── Upstream { output: [ payload, _rw_offset, _rw_table_name ], stream key: [] }

Fragment 22070 (Actor 99341,99340)
StreamDml { columns: [candidate_id, source_system, source_account_ref, source_asset_ref, account_id, asset_id, business_date, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at] }
├── output: [ candidate_id, source_system, source_account_ref, source_asset_ref, account_id, asset_id, business_date, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at ]
├── stream key: []
└── StreamSource { output: [ candidate_id, source_system, source_account_ref, source_asset_ref, account_id, asset_id, business_date, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at ], stream key: [] }