sdk_asset_enrichment_mv · explain

materialized view · adib_rm.sdk_asset_enrichment_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

15 operators

Materialize · adib_rm.sdk_asset_enrichment_mv

0% idle 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

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 23623 (Actor 104606,104605)
StreamMaterialize { columns: [asset_id, asset_name_en, asset_name_ar, asset_type, issue_currency_code, sharia_compliance, ticker, isin, latest_price, latest_price_date, price_change_pct_1d, asset_latest_price_mv_next.asset_id(hidden)], stream_key: [asset_id], pk_columns: [asset_id], pk_conflict: NoCheck }
├── output:
│   ┌── assets_dm.id
│   ├── assets_dm.name_en
│   ├── assets_dm.name_ar
│   ├── assets_dm.type
│   ├── assets_dm.issue_currency_code
│   ├── assets_dm.shariah_result
│   ├── 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.shariah_result
    │   ├── 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 23624 (Actor 104603,104604)
StreamSyncLogStore
├── output:
│   ┌── assets_dm.id
│   ├── assets_dm.name_en
│   ├── assets_dm.name_ar
│   ├── assets_dm.type
│   ├── assets_dm.issue_currency_code
│   ├── assets_dm.shariah_result
│   ├── 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.shariah_result
    │   ├── 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.shariah_result, 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 23625 (Actor 104601,104602)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, shariah_result, ticker, isin] }
├── output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.shariah_result, assets_dm.ticker, assets_dm.isin ]
├── stream key: [ assets_dm.id ]
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, shariah_result, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, shariah_result, ticker, isin ], stream key: [] }

Fragment 23626 (Actor 104607,104608)
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-adib.adib-rw.svc.cluster.local