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

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

Job is idle — throughput ~0; structure shown.

4 operators
Sink · adib_rm.settlement_orders_sink
0% idle 2 actors
StreamScan · settlement_orders_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.
Sink · adib_rm.settlement_orders_sink Sink adib_rm.settlement_orde… idle · 2 actors StreamScan · settlement_orders_mv_next StreamScan settlement_orders_mv_ne… 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 26187 (Actor 133894,133895)
StreamSink { type: upsert, columns: [order_id, client_order_id, external_order_id, security_account_id, asset_id, order_side, settlement_state, created_at, expected_settlement_date, settled_at, failure_reason, filled_quantity, est_net_amount, est_net_currency, settled_amount], downstream_pk: [settlement_orders_mv_next.order_id] }
├── output:
│   ┌── settlement_orders_mv_next.order_id
│   ├── settlement_orders_mv_next.client_order_id
│   ├── settlement_orders_mv_next.external_order_id
│   ├── settlement_orders_mv_next.security_account_id
│   ├── settlement_orders_mv_next.asset_id
│   ├── settlement_orders_mv_next.order_side
│   ├── settlement_orders_mv_next.settlement_state
│   ├── settlement_orders_mv_next.created_at
│   ├── settlement_orders_mv_next.expected_settlement_date
│   ├── settlement_orders_mv_next.settled_at
│   ├── settlement_orders_mv_next.failure_reason
│   ├── settlement_orders_mv_next.filled_quantity
│   ├── settlement_orders_mv_next.est_net_amount
│   ├── settlement_orders_mv_next.est_net_currency
│   └── settlement_orders_mv_next.settled_amount
├── stream key: [ settlement_orders_mv_next.order_id ]
└── StreamTableScan { table: settlement_orders_mv_next, columns: [order_id, client_order_id, external_order_id, security_account_id, asset_id, order_side, settlement_state, created_at, expected_settlement_date, settled_at, failure_reason, filled_quantity, est_net_amount, est_net_currency, settled_amount] }
    ├── output:
    │   ┌── settlement_orders_mv_next.order_id
    │   ├── settlement_orders_mv_next.client_order_id
    │   ├── settlement_orders_mv_next.external_order_id
    │   ├── settlement_orders_mv_next.security_account_id
    │   ├── settlement_orders_mv_next.asset_id
    │   ├── settlement_orders_mv_next.order_side
    │   ├── settlement_orders_mv_next.settlement_state
    │   ├── settlement_orders_mv_next.created_at
    │   ├── settlement_orders_mv_next.expected_settlement_date
    │   ├── settlement_orders_mv_next.settled_at
    │   ├── settlement_orders_mv_next.failure_reason
    │   ├── settlement_orders_mv_next.filled_quantity
    │   ├── settlement_orders_mv_next.est_net_amount
    │   ├── settlement_orders_mv_next.est_net_currency
    │   └── settlement_orders_mv_next.settled_amount
    ├── stream key: [ settlement_orders_mv_next.order_id ]
    ├── Upstream { output: [ order_id, client_order_id, external_order_id, security_account_id, asset_id, order_side, settlement_state, created_at, expected_settlement_date, settled_at, failure_reason, filled_quantity, est_net_amount, est_net_currency, settled_amount ], stream key: [] }
    └── BatchPlanNode { output: [ order_id, client_order_id, external_order_id, security_account_id, asset_id, order_side, settlement_state, created_at, expected_settlement_date, settled_at, failure_reason, filled_quantity, est_net_amount, est_net_currency, settled_amount ], stream key: [] }