orders_mv · explain — RWM Console

materialized view · alpheya_experience_bff.orders_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

6 operators

Materialize · alpheya_experience_bff.orders_mv

0% idle 2 actors

Project · orders

— — 2 actors

GroupTopN · orders

0% idle 2 actors

StreamScan · orders

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 12383 (Actor 156609,156608)
StreamMaterialize { 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], stream_key: [order_id], pk_columns: [order_id], pk_conflict: NoCheck }
├── output: [ orders.id, orders.etag, orders.client_order_id, orders.customer_relationship_id, orders.portfolio_id, orders.security_account_id, orders.asset_id, orders.side, orders.workflow_state, orders.execution_state, orders.instruction, orders.execution_spec, orders.cost_estimate, orders.initiator, orders.filled_quantity, orders.created_at ]
├── stream key: [ orders.id ]
└── StreamProject { exprs: [orders.id, orders.etag, orders.client_order_id, orders.customer_relationship_id, orders.portfolio_id, orders.security_account_id, orders.asset_id, orders.side, orders.workflow_state, orders.execution_state, orders.instruction, orders.execution_spec, orders.cost_estimate, orders.initiator, orders.filled_quantity, orders.created_at] }
    ├── output: [ orders.id, orders.etag, orders.client_order_id, orders.customer_relationship_id, orders.portfolio_id, orders.security_account_id, orders.asset_id, orders.side, orders.workflow_state, orders.execution_state, orders.instruction, orders.execution_spec, orders.cost_estimate, orders.initiator, orders.filled_quantity, orders.created_at ]
    ├── stream key: [ orders.id ]
    └── StreamGroupTopN { order: [orders.created_at DESC], limit: 1, offset: 0, group_key: [orders.id] }
        ├── output: [ orders.id, orders.client_order_id, orders.portfolio_id, orders.security_account_id, orders.initiator, orders.asset_id, orders.side, orders.workflow_state, orders.execution_state, orders.etag, orders.customer_relationship_id, orders.instruction, orders.execution_spec, orders.cost_estimate, orders.filled_quantity, orders.created_at ]
        ├── stream key: [ orders.id ]
        └── StreamTableScan { table: orders, columns: [id, client_order_id, portfolio_id, security_account_id, initiator, asset_id, side, workflow_state, execution_state, etag, customer_relationship_id, instruction, execution_spec, cost_estimate, filled_quantity, created_at] }
            ├── output: [ orders.id, orders.client_order_id, orders.portfolio_id, orders.security_account_id, orders.initiator, orders.asset_id, orders.side, orders.workflow_state, orders.execution_state, orders.etag, orders.customer_relationship_id, orders.instruction, orders.execution_spec, orders.cost_estimate, orders.filled_quantity, orders.created_at ]
            ├── stream key: [ orders.id, orders.created_at ]
            ├── Upstream { output: [ id, client_order_id, portfolio_id, security_account_id, initiator, asset_id, side, workflow_state, execution_state, etag, customer_relationship_id, instruction, execution_spec, cost_estimate, filled_quantity, created_at ], stream key: [] }
            └── BatchPlanNode { output: [ id, client_order_id, portfolio_id, security_account_id, initiator, asset_id, side, workflow_state, execution_state, etag, customer_relationship_id, instruction, execution_spec, cost_estimate, filled_quantity, created_at ], stream key: [] }

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