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

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

Job is idle — throughput ~0; structure shown.

6 operators
Sink · adib_rm.cash_holds_sink
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · cash_holds_mv
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.cash_holds_sink Sink adib_rm.cash_holds_sink idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · cash_holds_mv StreamScan cash_holds_mv 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 25039 (Actor 120057,120058)
StreamSink { type: upsert, columns: [cash_hold_id, order_id, provider_hold_id, funding_account_id, hold_amount, float_used, currency_code, status, created_at, updated_at, order_execution_state, order_executed_at, settlement_id, settlement_state, settlement_expected_date, settlement_settled_at], downstream_pk: [cash_holds_mv.cash_hold_id] }
├── output:
│   ┌── cash_holds_mv.cash_hold_id
│   ├── cash_holds_mv.order_id
│   ├── cash_holds_mv.provider_hold_id
│   ├── cash_holds_mv.funding_account_id
│   ├── cash_holds_mv.hold_amount
│   ├── cash_holds_mv.float_used
│   ├── cash_holds_mv.currency_code
│   ├── cash_holds_mv.status
│   ├── cash_holds_mv.created_at
│   ├── cash_holds_mv.updated_at
│   ├── cash_holds_mv.order_execution_state
│   ├── cash_holds_mv.order_executed_at
│   ├── cash_holds_mv.settlement_id
│   ├── cash_holds_mv.settlement_state
│   ├── cash_holds_mv.settlement_expected_date
│   └── cash_holds_mv.settlement_settled_at
├── stream key: [ cash_holds_mv.cash_hold_id, cash_holds_mv.order_id ]
└── MergeExecutor
    ├── output:
    │   ┌── cash_holds_mv.cash_hold_id
    │   ├── cash_holds_mv.order_id
    │   ├── cash_holds_mv.provider_hold_id
    │   ├── cash_holds_mv.funding_account_id
    │   ├── cash_holds_mv.hold_amount
    │   ├── cash_holds_mv.float_used
    │   ├── cash_holds_mv.currency_code
    │   ├── cash_holds_mv.status
    │   ├── cash_holds_mv.created_at
    │   ├── cash_holds_mv.updated_at
    │   ├── cash_holds_mv.order_execution_state
    │   ├── cash_holds_mv.order_executed_at
    │   ├── cash_holds_mv.settlement_id
    │   ├── cash_holds_mv.settlement_state
    │   ├── cash_holds_mv.settlement_expected_date
    │   └── cash_holds_mv.settlement_settled_at
    └── stream key: [ cash_holds_mv.cash_hold_id, cash_holds_mv.order_id ]

Fragment 25040 (Actor 120059,120060)
StreamTableScan { table: cash_holds_mv, columns: [cash_hold_id, order_id, provider_hold_id, funding_account_id, hold_amount, float_used, currency_code, status, created_at, updated_at, order_execution_state, order_executed_at, settlement_id, settlement_state, settlement_expected_date, settlement_settled_at] }
├── output:
│   ┌── cash_holds_mv.cash_hold_id
│   ├── cash_holds_mv.order_id
│   ├── cash_holds_mv.provider_hold_id
│   ├── cash_holds_mv.funding_account_id
│   ├── cash_holds_mv.hold_amount
│   ├── cash_holds_mv.float_used
│   ├── cash_holds_mv.currency_code
│   ├── cash_holds_mv.status
│   ├── cash_holds_mv.created_at
│   ├── cash_holds_mv.updated_at
│   ├── cash_holds_mv.order_execution_state
│   ├── cash_holds_mv.order_executed_at
│   ├── cash_holds_mv.settlement_id
│   ├── cash_holds_mv.settlement_state
│   ├── cash_holds_mv.settlement_expected_date
│   └── cash_holds_mv.settlement_settled_at
├── stream key: [ cash_holds_mv.cash_hold_id, cash_holds_mv.order_id ]
├── Upstream { output: [ cash_hold_id, order_id, provider_hold_id, funding_account_id, hold_amount, float_used, currency_code, status, created_at, updated_at, order_execution_state, order_executed_at, settlement_id, settlement_state, settlement_expected_date, settlement_settled_at ], stream key: [] }
└── BatchPlanNode { output: [ cash_hold_id, order_id, provider_hold_id, funding_account_id, hold_amount, float_used, currency_code, status, created_at, updated_at, order_execution_state, order_executed_at, settlement_id, settlement_state, settlement_expected_date, settlement_settled_at ], stream key: [] }