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

CREATE MATERIALIZED VIEW insights.intraday_asset_prices_latest_mv AS
WITH intraday AS (
  SELECT
    asset_id,
    ARG_MAX(last_price, window_start) AS last_price,
    MAX(value_timestamp) AS value_timestamp
  FROM insights.intraday_asset_prices_5min_mv
  GROUP BY
    asset_id
), asset_keys AS (
  SELECT
    asset_id
  FROM (
    SELECT
      asset_id
    FROM intraday
    UNION ALL
    SELECT
      asset_id
    FROM insights.asset_prices_snapshot_mv AS asset_prices_snapshot_mv_next
  )
  GROUP BY
    asset_id
)
SELECT
  k.asset_id,
  COALESCE(i.last_price, e.close) AS last_price,
  CASE WHEN NOT i.last_price IS NULL THEN i.value_timestamp ELSE e.value_timestamp END AS value_timestamp
FROM asset_keys AS k
LEFT JOIN intraday AS i
  ON i.asset_id = k.asset_id
LEFT JOIN insights.asset_prices_snapshot_mv AS e
  ON e.asset_id = k.asset_id