cash_holds_sink · explain

sink · adib_rm.cash_holds_sink profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

6 operators

Sink · adib_rm.cash_holds_sink

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · cash_holds_mv_next

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.

Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.

Fragments (DESCRIBE FRAGMENTS) — click to expand

Fragment 23251 (Actor 101894,101895)
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_next.cash_hold_id] }
├── output:
│   ┌── cash_holds_mv_next.cash_hold_id
│   ├── cash_holds_mv_next.order_id
│   ├── cash_holds_mv_next.provider_hold_id
│   ├── cash_holds_mv_next.funding_account_id
│   ├── cash_holds_mv_next.hold_amount
│   ├── cash_holds_mv_next.float_used
│   ├── cash_holds_mv_next.currency_code
│   ├── cash_holds_mv_next.status
│   ├── cash_holds_mv_next.created_at
│   ├── cash_holds_mv_next.updated_at
│   ├── cash_holds_mv_next.order_execution_state
│   ├── cash_holds_mv_next.order_executed_at
│   ├── cash_holds_mv_next.settlement_id
│   ├── cash_holds_mv_next.settlement_state
│   ├── cash_holds_mv_next.settlement_expected_date
│   └── cash_holds_mv_next.settlement_settled_at
├── stream key: [ cash_holds_mv_next.cash_hold_id, cash_holds_mv_next.order_id ]
└── MergeExecutor
    ├── output:
    │   ┌── cash_holds_mv_next.cash_hold_id
    │   ├── cash_holds_mv_next.order_id
    │   ├── cash_holds_mv_next.provider_hold_id
    │   ├── cash_holds_mv_next.funding_account_id
    │   ├── cash_holds_mv_next.hold_amount
    │   ├── cash_holds_mv_next.float_used
    │   ├── cash_holds_mv_next.currency_code
    │   ├── cash_holds_mv_next.status
    │   ├── cash_holds_mv_next.created_at
    │   ├── cash_holds_mv_next.updated_at
    │   ├── cash_holds_mv_next.order_execution_state
    │   ├── cash_holds_mv_next.order_executed_at
    │   ├── cash_holds_mv_next.settlement_id
    │   ├── cash_holds_mv_next.settlement_state
    │   ├── cash_holds_mv_next.settlement_expected_date
    │   └── cash_holds_mv_next.settlement_settled_at
    └── stream key: [ cash_holds_mv_next.cash_hold_id, cash_holds_mv_next.order_id ]

Fragment 23252 (Actor 99649,99650)
StreamTableScan { table: cash_holds_mv_next, 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_next.cash_hold_id
│   ├── cash_holds_mv_next.order_id
│   ├── cash_holds_mv_next.provider_hold_id
│   ├── cash_holds_mv_next.funding_account_id
│   ├── cash_holds_mv_next.hold_amount
│   ├── cash_holds_mv_next.float_used
│   ├── cash_holds_mv_next.currency_code
│   ├── cash_holds_mv_next.status
│   ├── cash_holds_mv_next.created_at
│   ├── cash_holds_mv_next.updated_at
│   ├── cash_holds_mv_next.order_execution_state
│   ├── cash_holds_mv_next.order_executed_at
│   ├── cash_holds_mv_next.settlement_id
│   ├── cash_holds_mv_next.settlement_state
│   ├── cash_holds_mv_next.settlement_expected_date
│   └── cash_holds_mv_next.settlement_settled_at
├── stream key: [ cash_holds_mv_next.cash_hold_id, cash_holds_mv_next.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: [] }

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