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

← cluster insights objects asset_price_with_lag_mv
Overview Objects Graph History
materialized view · insights.asset_price_with_lag_mv Explain plan ▶
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
580,057
State size
48.1 MiB
Created
2026-08-21 06:24
Initialized
2026-08-21 06:23
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
157828 17892 33 running
157829 17892 33 running
157830 17893 33 running
157831 17893 33 running
157832 17894 33 running
157833 17894 33 running
157838 17895 33 running
157839 17895 33 running
157840 17896 33 running
157841 17896 33 running
sql · insights.asset_price_with_lag_mv — click to expand
CREATE MATERIALIZED VIEW insights.asset_price_with_lag_mv AS
SELECT
  asset_id,
  fact_date,
  px AS adjusted_last_close_price,
  LAG(px) OVER (PARTITION BY asset_id ORDER BY fact_date) AS prev_price
FROM (
  SELECT
    eod.asset_id,
    eod.date AS fact_date,
    COALESCE(adj.adjusted_close, eod.close) AS px
  FROM asset_service.asset_prices_eod_ft AS eod
  LEFT JOIN asset_service.asset_adjusted_prices_ft AS adj
    ON adj.asset_id = eod.asset_id AND adj.date = eod.date
  WHERE
    NOT eod.close IS NULL
)
Lineage · insights.asset_price_with_lag_mv 6 objects
Direct (1-hop) dependencies from rw_depend, across schemas. Click a neighbor to expand its dependencies; ⌘/Ctrl-click opens its page. Drag to pan, scroll to zoom. External source/sink endpoints (Kafka, Iceberg) are not shown.