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

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

Job is idle — throughput ~0; structure shown.

5 operators
Sink · adib_rm.holding_candidates_sink
0% idle 2 actors
Project · ibor_holding_candidates
— — 2 actors
StreamScan · ibor_holding_candidates
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 · adib_rm.holding_candidates_sink Sink adib_rm.holding_candida… idle · 2 actors Project · ibor_holding_candidates Project ibor_holding_candidates — · 2 actors StreamScan · ibor_holding_candidates StreamScan ibor_holding_candidates 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 25025 (Actor 119861,119860)
StreamSink { type: upsert, columns: [candidate_id, source_system, business_date, source_account_ref, source_asset_ref, account_id, asset_id, quantity, market_value, market_value_currency, average_cost_per_unit, source_revision, superseded_revision, reconciled_revision, updated_at], downstream_pk: [ibor_holding_candidates.candidate_id] }
├── output: [ ibor_holding_candidates.candidate_id, ibor_holding_candidates.source_system, ibor_holding_candidates.business_date, ibor_holding_candidates.source_account_ref, ibor_holding_candidates.source_asset_ref, ibor_holding_candidates.account_id, ibor_holding_candidates.asset_id, ibor_holding_candidates.quantity, ibor_holding_candidates.market_value, ibor_holding_candidates.market_value_currency, ibor_holding_candidates.average_cost_per_unit, ibor_holding_candidates.source_revision, ibor_holding_candidates.superseded_revision, ibor_holding_candidates.reconciled_revision, ibor_holding_candidates.updated_at ]
├── stream key: [ ibor_holding_candidates.candidate_id ]
└── StreamProject { exprs: [ibor_holding_candidates.candidate_id, ibor_holding_candidates.source_system, ibor_holding_candidates.business_date, ibor_holding_candidates.source_account_ref, ibor_holding_candidates.source_asset_ref, ibor_holding_candidates.account_id, ibor_holding_candidates.asset_id, ibor_holding_candidates.quantity, ibor_holding_candidates.market_value, ibor_holding_candidates.market_value_currency, ibor_holding_candidates.average_cost_per_unit, ibor_holding_candidates.source_revision, ibor_holding_candidates.superseded_revision, ibor_holding_candidates.reconciled_revision, ibor_holding_candidates.updated_at] }
    ├── output: [ ibor_holding_candidates.candidate_id, ibor_holding_candidates.source_system, ibor_holding_candidates.business_date, ibor_holding_candidates.source_account_ref, ibor_holding_candidates.source_asset_ref, ibor_holding_candidates.account_id, ibor_holding_candidates.asset_id, ibor_holding_candidates.quantity, ibor_holding_candidates.market_value, ibor_holding_candidates.market_value_currency, ibor_holding_candidates.average_cost_per_unit, ibor_holding_candidates.source_revision, ibor_holding_candidates.superseded_revision, ibor_holding_candidates.reconciled_revision, ibor_holding_candidates.updated_at ]
    ├── stream key: [ ibor_holding_candidates.candidate_id ]
    └── StreamTableScan { table: 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: [ ibor_holding_candidates.candidate_id, ibor_holding_candidates.source_system, ibor_holding_candidates.source_account_ref, ibor_holding_candidates.source_asset_ref, ibor_holding_candidates.account_id, ibor_holding_candidates.asset_id, ibor_holding_candidates.business_date, ibor_holding_candidates.quantity, ibor_holding_candidates.market_value, ibor_holding_candidates.market_value_currency, ibor_holding_candidates.average_cost_per_unit, ibor_holding_candidates.source_revision, ibor_holding_candidates.superseded_revision, ibor_holding_candidates.reconciled_revision, ibor_holding_candidates.updated_at ]
        ├── stream key: [ ibor_holding_candidates.candidate_id ]
        ├── Upstream { 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: [] }
        └── BatchPlanNode { 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: [] }