Offline change point detection (PELT, binary segmentation, dynamic programming, CROPS)
Compatibility Matrix
This table covers all DuckDB releases that have not reached end-of-life, including LTS releases, and shows the 2 most recent patch releases of each. Older patch releases are not listed, but the extension may be available for them as well.
| Platform | 1.4.4 | 1.4.5 | 1.5.5 | 1.5.6 | 2.0.0 |
|---|---|---|---|---|---|
| Linux AMD64 | |||||
| Linux ARM64 | |||||
| macOS AMD64 | |||||
| macOS ARM64 | |||||
| Windows AMD64 | |||||
| Windows ARM64 | |||||
| WebAssembly |
Installing and Loading
INSTALL cpt FROM community;
LOAD cpt;
Example
LOAD cpt;
-- Two sensors, one reading per minute for a day. Sensor 1 steps up by 3 at 10:00.
-- The noise is a sine, so the result is the same on every DuckDB version.
CREATE TABLE readings AS
SELECT s AS sensor_id,
TIMESTAMP '2026-01-01' + INTERVAL (i) MINUTE AS ts,
20 + CASE WHEN s = 1 AND i >= 600 THEN 3 ELSE 0 END + sin(i * 1.7 + s) AS value
FROM range(1, 3) a(s), range(1440) b(i);
-- 1-based segment ends per sensor; the last one is the length of the series
SELECT sensor_id, cpt_pelt(list(value ORDER BY ts), 'l2') AS segment_ends
FROM readings
GROUP BY sensor_id
ORDER BY sensor_id;
-- 1 | [600, 1440]
-- 2 | [1440]
-- When each change happened: every segment end but the last is followed by a new segment
WITH s AS (
SELECT sensor_id, list(ts ORDER BY ts) AS tss, list(value ORDER BY ts) AS xs
FROM readings
GROUP BY sensor_id
)
SELECT sensor_id, tss[e + 1] AS changed_at
FROM s, unnest(cpt_pelt(xs, 'l2')[:-2]) AS u(e);
-- 1 | 2026-01-01 10:00:00
-- Mean and variance of every segment
SELECT sensor_id, unnest(cpt_segment_stats(xs, cpt_pelt(xs, 'l2')), recursive := true)
FROM (SELECT sensor_id, list(value ORDER BY ts) AS xs FROM readings GROUP BY sensor_id)
ORDER BY ALL;
About cpt
cpt finds the points where an ordered series changes its behaviour: a level shift, a change in variance, in the rate of counts or in the median. cpt_pelt, cpt_binseg and cpt_dynp take one series per row as DOUBLE[] (build it with list(x ORDER BY ts)) and return the 1-based end positions of the segments, the last one equal to the length of the series. cpt_crops returns every optimal segmentation over a range of penalties, and cpt_segment_stats returns statistics for given segment ends.
- cpt_pelt: the exact optimum of the penalised cost (PELT, Killick et al. 2012), with exact pruning also when a minimum segment length is set.
- cpt_binseg: binary segmentation, O(n log n), stops after n_bkps splits or at a penalty.
- cpt_dynp: the optimal split into exactly n_bkps + 1 segments.
- cpt_crops: every distinct optimal segmentation over a range of penalties (CROPS).
- cpt_segment_stats: start, end, mean, variance and length of every segment.
Costs: 'l2' (mean), 'normal' (mean and variance), 'poisson' (counts), 'l1' (median). Penalties: a number, or 'bic' (default), 'mbic', 'aic' with the values of R's changepoint package. Results are checked against ruptures and R changepoint.
A running scalar function cannot be interrupted, so the work on one series is capped by the setting cpt_max_evaluations (default 1e9 evaluation units, 0 = no limit).
Written in C11 on the stable C API: one binary loads in DuckDB 1.5.6 and later. Documentation: https://github.com/hugr-lab/duck-changepoint
Added Functions
| function_name | function_type | description | comment | examples |
|---|---|---|---|---|
| cpt_binseg | scalar | NULL | NULL | |
| cpt_crops | scalar | NULL | NULL | |
| cpt_dynp | scalar | NULL | NULL | |
| cpt_pelt | scalar | NULL | NULL | |
| cpt_segment_stats | scalar | NULL | NULL |
Overloaded Functions
This extension does not add any function overloads.
Added Types
This extension does not add any types.
Added Settings
| name | description | input_type | scope | aliases | typed_value |
|---|---|---|---|---|---|
| cpt_max_evaluations | Maximum work per cpt_* call on one series, in segment cost evaluations (an l1 evaluation counts log2(n)); 0 = no limit. Bounds run time, since a running call cannot be interrupted. | BIGINT | GLOBAL | [] | 1000000000 |
| temp_directory | Set the directory to which temporary files are written. | VARCHAR | GLOBAL | [] | post.db.tmp |