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

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

Job is idle — throughput ~0; structure shown.

6 operators
Sink · alpheya_agent.transactions_sink
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transactions_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_agent.transactions_sink Sink alpheya_agent.transacti… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · transactions_mv StreamScan transactions_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 19408 (Actor 157444,157443)
StreamSink { type: upsert, columns: [transaction_id, account_id, portfolio_id, asset_id, transaction_type, transaction_type_id, currency_code, quantity, unit_price, gross_value, net_value, valuation_date, settlement_date, order_id, external_reference, description], downstream_pk: [transactions_mv.transaction_id] }
├── output:
│   ┌── transactions_mv.transaction_id
│   ├── transactions_mv.account_id
│   ├── transactions_mv.portfolio_id
│   ├── transactions_mv.asset_id
│   ├── transactions_mv.transaction_type
│   ├── transactions_mv.transaction_type_id
│   ├── transactions_mv.currency_code
│   ├── transactions_mv.quantity
│   ├── transactions_mv.unit_price
│   ├── transactions_mv.gross_value
│   ├── transactions_mv.net_value
│   ├── transactions_mv.valuation_date
│   ├── transactions_mv.settlement_date
│   ├── transactions_mv.order_id
│   ├── transactions_mv.external_reference
│   └── transactions_mv.description
├── stream key: [ transactions_mv.transaction_type_id, transactions_mv.transaction_id ]
└── MergeExecutor
    ├── output:
    │   ┌── transactions_mv.transaction_id
    │   ├── transactions_mv.account_id
    │   ├── transactions_mv.portfolio_id
    │   ├── transactions_mv.asset_id
    │   ├── transactions_mv.transaction_type
    │   ├── transactions_mv.transaction_type_id
    │   ├── transactions_mv.currency_code
    │   ├── transactions_mv.quantity
    │   ├── transactions_mv.unit_price
    │   ├── transactions_mv.gross_value
    │   ├── transactions_mv.net_value
    │   ├── transactions_mv.valuation_date
    │   ├── transactions_mv.settlement_date
    │   ├── transactions_mv.order_id
    │   ├── transactions_mv.external_reference
    │   └── transactions_mv.description
    └── stream key: [ transactions_mv.transaction_type_id, transactions_mv.transaction_id ]

Fragment 19409 (Actor 157446,157447)
StreamTableScan { table: transactions_mv, columns: [transaction_id, account_id, portfolio_id, asset_id, transaction_type, transaction_type_id, currency_code, quantity, unit_price, gross_value, net_value, valuation_date, settlement_date, order_id, external_reference, description] }
├── output:
│   ┌── transactions_mv.transaction_id
│   ├── transactions_mv.account_id
│   ├── transactions_mv.portfolio_id
│   ├── transactions_mv.asset_id
│   ├── transactions_mv.transaction_type
│   ├── transactions_mv.transaction_type_id
│   ├── transactions_mv.currency_code
│   ├── transactions_mv.quantity
│   ├── transactions_mv.unit_price
│   ├── transactions_mv.gross_value
│   ├── transactions_mv.net_value
│   ├── transactions_mv.valuation_date
│   ├── transactions_mv.settlement_date
│   ├── transactions_mv.order_id
│   ├── transactions_mv.external_reference
│   └── transactions_mv.description
├── stream key: [ transactions_mv.transaction_type_id, transactions_mv.transaction_id ]
├── Upstream { output: [ transaction_id, account_id, portfolio_id, asset_id, transaction_type, transaction_type_id, currency_code, quantity, unit_price, gross_value, net_value, valuation_date, settlement_date, order_id, external_reference, description ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, account_id, portfolio_id, asset_id, transaction_type, transaction_type_id, currency_code, quantity, unit_price, gross_value, net_value, valuation_date, settlement_date, order_id, external_reference, description ], stream key: [] }