orders_sink · explain

sink · alinma_bff.orders_sink profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

4 operators

Sink · alinma_bff.orders_sink

0% idle 2 actors

StreamScan · orders_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.

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

Fragments (DESCRIBE FRAGMENTS) — click to expand

Fragment 52800 (Actor 738242,738241)
StreamSink { type: upsert, columns: [order_id, etag, client_order_id, customer_relationship_id, portfolio_id, security_account_id, asset_id, order_side, workflow_state, execution_state, termination_reason, termination_detail, instruction, execution_spec, cost_estimate, execution_summary, initiator, filled_quantity, created_at, executed_at], downstream_pk: [orders_mv.order_id] }
├── output:
│   ┌── orders_mv.order_id
│   ├── orders_mv.etag
│   ├── orders_mv.client_order_id
│   ├── orders_mv.customer_relationship_id
│   ├── orders_mv.portfolio_id
│   ├── orders_mv.security_account_id
│   ├── orders_mv.asset_id
│   ├── orders_mv.order_side
│   ├── orders_mv.workflow_state
│   ├── orders_mv.execution_state
│   ├── orders_mv.termination_reason
│   ├── orders_mv.termination_detail
│   ├── orders_mv.instruction
│   ├── orders_mv.execution_spec
│   ├── orders_mv.cost_estimate
│   ├── orders_mv.execution_summary
│   ├── orders_mv.initiator
│   ├── orders_mv.filled_quantity
│   ├── orders_mv.created_at
│   └── orders_mv.executed_at
├── stream key: [ orders_mv.order_id ]
└── StreamTableScan { table: orders_mv, columns: [order_id, etag, client_order_id, customer_relationship_id, portfolio_id, security_account_id, asset_id, order_side, workflow_state, execution_state, termination_reason, termination_detail, instruction, execution_spec, cost_estimate, execution_summary, initiator, filled_quantity, created_at, executed_at] }
    ├── output:
    │   ┌── orders_mv.order_id
    │   ├── orders_mv.etag
    │   ├── orders_mv.client_order_id
    │   ├── orders_mv.customer_relationship_id
    │   ├── orders_mv.portfolio_id
    │   ├── orders_mv.security_account_id
    │   ├── orders_mv.asset_id
    │   ├── orders_mv.order_side
    │   ├── orders_mv.workflow_state
    │   ├── orders_mv.execution_state
    │   ├── orders_mv.termination_reason
    │   ├── orders_mv.termination_detail
    │   ├── orders_mv.instruction
    │   ├── orders_mv.execution_spec
    │   ├── orders_mv.cost_estimate
    │   ├── orders_mv.execution_summary
    │   ├── orders_mv.initiator
    │   ├── orders_mv.filled_quantity
    │   ├── orders_mv.created_at
    │   └── orders_mv.executed_at
    ├── stream key: [ orders_mv.order_id ]
    ├── Upstream { output: [ order_id, etag, client_order_id, customer_relationship_id, portfolio_id, security_account_id, asset_id, order_side, workflow_state, execution_state, termination_reason, termination_detail, instruction, execution_spec, cost_estimate, execution_summary, initiator, filled_quantity, created_at, executed_at ], stream key: [] }
    └── BatchPlanNode { output: [ order_id, etag, client_order_id, customer_relationship_id, portfolio_id, security_account_id, asset_id, order_side, workflow_state, execution_state, termination_reason, termination_detail, instruction, execution_spec, cost_estimate, execution_summary, initiator, filled_quantity, created_at, executed_at ], stream key: [] }

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