public.stg_tepco_demand_5min

CREATE VIEW stg_tepco_demand_5min AS (
 WITH deduplicated AS (
         SELECT raw_tepco_demand_5min.id,
            raw_tepco_demand_5min.date_str,
            raw_tepco_demand_5min.time_str,
            raw_tepco_demand_5min.demand_mw_str,
            raw_tepco_demand_5min.solar_mw_str,
            raw_tepco_demand_5min.solar_pct_str,
            raw_tepco_demand_5min.loaded_at,
            row_number() OVER (PARTITION BY raw_tepco_demand_5min.date_str, raw_tepco_demand_5min.time_str ORDER BY raw_tepco_demand_5min.loaded_at DESC) AS row_num
           FROM raw_tepco_demand_5min
          WHERE (raw_tepco_demand_5min.demand_mw_str IS NOT NULL)
        )
 SELECT deduplicated.id,
    to_date(deduplicated.date_str, 'YYYY/MM/DD'::text) AS demand_date,
    (deduplicated.time_str)::time without time zone AS demand_time,
    ((deduplicated.demand_mw_str)::numeric * (10)::numeric) AS demand_mw,
    ((deduplicated.solar_mw_str)::numeric * (10)::numeric) AS solar_mw,
    (deduplicated.solar_pct_str)::numeric AS solar_pct,
    deduplicated.loaded_at
   FROM deduplicated
  WHERE (deduplicated.row_num = 1)
)