marketplace_assets_mv · explain

materialized view · alinma_bff.marketplace_assets_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

Heat tree Operator graph

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.id = asset_latest_price_mv_next.asset_id

— — 2 actors

HashJoin · LeftOuter · assets_dm.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

— — 2 actors

Filter · assets_dm

0% idle 2 actors

StreamScan · assets_dm

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 56725 (Actor 737609,737608)
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.id, $expr1, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.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.id ]
└── StreamProject { exprs: [assets_dm.id, Coalesce(assets_dm.ticker, '':Varchar) as $expr1, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.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.id, $expr1, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.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.id ]
    └── MergeExecutor
        ├── output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id ]

Fragment 56726 (Actor 737613,737612)
StreamSyncLogStore
├── output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id ]
└── StreamHashJoin { type: LeftOuter, predicate: assets_dm.id = asset_latest_price_mv_next.asset_id }
    ├── output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id ]
    ├── MergeExecutor { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.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 56727 (Actor 737614,737615)
StreamProject { exprs: [assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin] }
├── output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ]
├── stream key: [ assets_dm.id ]
└── StreamFilter { predicate: IsNull(assets_dm.disabled_at) } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.disabled_at ], stream key: [ assets_dm.id ] }
    └── StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin, disabled_at] }
        ├── output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.disabled_at ]
        ├── stream key: [ assets_dm.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 56728 (Actor 737616,737617)
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: [] }

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