Month-end closes that set a new high for the window, by year (SPY)

Run it yourself

This is the exact query behind the result above. Change a ticker, a date or a column and run it against the warehouse — no account, no key. The no-signup tier is smaller than the one this page was computed on; a query that reaches past it comes back saying which plan runs it.

WITH daily AS
(
    SELECT
        toDate(toTimeZone(window_start, 'America/New_York')) AS d,
        argMax(close, window_start)                          AS px
    FROM global_markets.delayed_stocks_minute_aggs
    WHERE ticker = 'SPY'
      AND window_start >= toDateTime('2006-01-01 00:00:00')
      AND (toHour(toTimeZone(window_start, 'America/New_York')) * 60
           + toMinute(toTimeZone(window_start, 'America/New_York'))) >= 570
      AND (toHour(toTimeZone(window_start, 'America/New_York')) * 60
           + toMinute(toTimeZone(window_start, 'America/New_York'))) < 960
    GROUP BY d
),
month_close AS
(
    SELECT
        toStartOfMonth(d)          AS m,
        toFloat64(argMax(px, d))   AS close_px
    FROM daily
    GROUP BY m
),
peaks AS
(
    SELECT
        m,
        close_px,
        max(close_px) OVER (ORDER BY m ASC
            ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW) AS running_peak
    FROM month_close
),
per_year AS
(
    SELECT
        toYear(m)                         AS y,
        count()                           AS closes_observed,
        countIf(close_px >= running_peak) AS new_highs
    FROM peaks
    GROUP BY y
)
SELECT
    toString(y)      AS year,
    closes_observed,
    new_highs,
    round(100 * sum(new_highs) OVER (ORDER BY y ASC
              ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)
              / sum(closes_observed) OVER (ORDER BY y ASC
              ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW), 1) AS cumulative_share_pct
FROM per_year
ORDER BY y