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

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

Job is idle — throughput ~0; structure shown.

4 operators
Sink · alpheya_agent.fx_rates_eod_sink
0% idle 2 actors
StreamScan · fx_rates_eod_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.fx_rates_eod_sink Sink alpheya_agent.fx_rates_… idle · 2 actors StreamScan · fx_rates_eod_mv StreamScan fx_rates_eod_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 19411 (Actor 157453,157452)
StreamSink { type: upsert, columns: [rate_date, base_currency, quote_currency, rate], downstream_pk: [fx_rates_eod_mv.rate_date, fx_rates_eod_mv.base_currency, fx_rates_eod_mv.quote_currency] }
├── output: [ fx_rates_eod_mv.rate_date, fx_rates_eod_mv.base_currency, fx_rates_eod_mv.quote_currency, fx_rates_eod_mv.rate ]
├── stream key: [ fx_rates_eod_mv.base_currency, fx_rates_eod_mv.quote_currency, fx_rates_eod_mv.rate_date ]
└── StreamTableScan { table: fx_rates_eod_mv, columns: [rate_date, base_currency, quote_currency, rate] }
    ├── output: [ fx_rates_eod_mv.rate_date, fx_rates_eod_mv.base_currency, fx_rates_eod_mv.quote_currency, fx_rates_eod_mv.rate ]
    ├── stream key: [ fx_rates_eod_mv.base_currency, fx_rates_eod_mv.quote_currency, fx_rates_eod_mv.rate_date ]
    ├── Upstream { output: [ rate_date, base_currency, quote_currency, rate ], stream key: [] }
    └── BatchPlanNode { output: [ rate_date, base_currency, quote_currency, rate ], stream key: [] }