RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

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

Job is idle — throughput ~0; structure shown.

4 operators
Sink · alpheya_experience_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.
Sink · alpheya_experience_bff.orders_sink Sink alpheya_experience_bff.… idle · 2 actors StreamScan · orders_mv StreamScan orders_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 12612 (Actor 157414,157413)
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, instruction, execution_spec, cost_estimate, initiator, filled_quantity, created_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.instruction
│   ├── orders_mv.execution_spec
│   ├── orders_mv.cost_estimate
│   ├── orders_mv.initiator
│   ├── orders_mv.filled_quantity
│   └── orders_mv.created_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, instruction, execution_spec, cost_estimate, initiator, filled_quantity, created_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.instruction
    │   ├── orders_mv.execution_spec
    │   ├── orders_mv.cost_estimate
    │   ├── orders_mv.initiator
    │   ├── orders_mv.filled_quantity
    │   └── orders_mv.created_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, instruction, execution_spec, cost_estimate, initiator, filled_quantity, created_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, instruction, execution_spec, cost_estimate, initiator, filled_quantity, created_at ], stream key: [] }