RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local

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

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
18 operators
Materialize · alinma_bff.marketplace_assets_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · assets_dm_next.id = asset_latest_price_mv_next.asset_id
— — 2 actors
HashJoin · LeftOuter · assets_dm_next.id = asset_latest_price_mv_next.asset_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · asset_latest_price_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · assets_dm_next
— — 2 actors
Filter · assets_dm_next
0% idle 2 actors
StreamScan · assets_dm_next
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 · alinma_bff.marketplace_assets_mv Materialize alinma_bff.marketplace_… idle · 2 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · assets_dm_next.id = asset_latest_price_mv_next.asset_id SyncLogStore LeftOuter · assets_dm_n… — · 2 actors HashJoin · LeftOuter · assets_dm_next.id = asset_latest_price_mv_next.asset_id HashJoin LeftOuter · assets_dm_n… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · asset_latest_price_mv_next StreamScan asset_latest_price_mv_n… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · assets_dm_next Project assets_dm_next — · 2 actors Filter · assets_dm_next Filter assets_dm_next idle · 2 actors StreamScan · assets_dm_next StreamScan assets_dm_next 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 62583 (Actor 743022,743021)
StreamMaterialize { columns: [asset_id, ticker, name_en, name_ar, asset_type, currency_code, isin, price, price_date, price_change_percent], stream_key: [asset_id], pk_columns: [asset_id], pk_conflict: NoCheck }
├── output: [ assets_dm_next.id, $expr1, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.isin, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d ]
├── stream key: [ assets_dm_next.id ]
└── StreamProject { exprs: [assets_dm_next.id, Coalesce(assets_dm_next.ticker, '':Varchar) as $expr1, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.isin, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d] }
    ├── output: [ assets_dm_next.id, $expr1, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.isin, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d ]
    ├── stream key: [ assets_dm_next.id ]
    └── MergeExecutor
        ├── output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d, asset_latest_price_mv_next.asset_id ]
        └── stream key: [ assets_dm_next.id ]

Fragment 62584 (Actor 743024,743023)
StreamSyncLogStore
├── output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d, asset_latest_price_mv_next.asset_id ]
├── stream key: [ assets_dm_next.id ]
└── StreamHashJoin { type: LeftOuter, predicate: assets_dm_next.id = asset_latest_price_mv_next.asset_id }
    ├── output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d, asset_latest_price_mv_next.asset_id ]
    ├── stream key: [ assets_dm_next.id ]
    ├── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }
    └── MergeExecutor { output: [ asset_latest_price_mv_next.asset_id, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d ], stream key: [ asset_latest_price_mv_next.asset_id ] }

Fragment 62585 (Actor 743709,743710)
StreamProject { exprs: [assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin] }
├── output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ]
├── stream key: [ assets_dm_next.id ]
└── StreamFilter { predicate: IsNull(assets_dm_next.disabled_at) } { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.disabled_at ], stream key: [ assets_dm_next.id ] }
    └── StreamTableScan { table: assets_dm_next, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin, disabled_at] }
        ├── output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.disabled_at ]
        ├── stream key: [ assets_dm_next.id ]
        ├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin, disabled_at ], stream key: [] }

Fragment 62586 (Actor 743048,743047)
StreamTableScan { table: asset_latest_price_mv_next, columns: [asset_id, price, price_date, price_change_pct_1d] } { output: [ asset_latest_price_mv_next.asset_id, asset_latest_price_mv_next.price, asset_latest_price_mv_next.price_date, asset_latest_price_mv_next.price_change_pct_1d ], stream key: [ asset_latest_price_mv_next.asset_id ] }
├── Upstream { output: [ asset_id, price, price_date, price_change_pct_1d ], stream key: [] }
└── BatchPlanNode { output: [ asset_id, price, price_date, price_change_pct_1d ], stream key: [] }