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

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

Job is idle — throughput ~0; structure shown.

6 operators
Materialize · alpheya_agent.fx_rates_eod_mv
0% idle 2 actors
Project · foreign_exchange_rates_eod_ft
— — 2 actors
Filter · foreign_exchange_rates_eod_ft
0% idle 2 actors
StreamScan · foreign_exchange_rates_eod_ft
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.
Materialize · alpheya_agent.fx_rates_eod_mv Materialize alpheya_agent.fx_rates_… idle · 2 actors Project · foreign_exchange_rates_eod_ft Project foreign_exchange_rates_… — · 2 actors Filter · foreign_exchange_rates_eod_ft Filter foreign_exchange_rates_… idle · 2 actors StreamScan · foreign_exchange_rates_eod_ft StreamScan foreign_exchange_rates_… 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 19404 (Actor 157433,157434)
StreamMaterialize { columns: [rate_date, base_currency, quote_currency, rate], stream_key: [base_currency, quote_currency, rate_date], pk_columns: [base_currency, quote_currency, rate_date], pk_conflict: NoCheck }
├── output: [ foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.rate ]
├── stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ]
└── StreamProject { exprs: [foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.rate] }
    ├── output: [ foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.rate ]
    ├── stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ]
    └── StreamFilter { predicate: (foreign_exchange_rates_eod_ft.source_currency_code = 'USD':Varchar) }
        ├── output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ]
        ├── stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ]
        └── StreamTableScan { table: foreign_exchange_rates_eod_ft, columns: [source_currency_code, target_currency_code, date, rate] }
            ├── output: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date, foreign_exchange_rates_eod_ft.rate ]
            ├── stream key: [ foreign_exchange_rates_eod_ft.source_currency_code, foreign_exchange_rates_eod_ft.target_currency_code, foreign_exchange_rates_eod_ft.date ]
            ├── Upstream { output: [ source_currency_code, target_currency_code, date, rate ], stream key: [] }
            └── BatchPlanNode { output: [ source_currency_code, target_currency_code, date, rate ], stream key: [] }