pub fn roll_raw_to_1m(
conn: &Connection,
now_ms: i64,
grace_ms: i64,
) -> Result<usize>Expand description
One raw→1m pass: aggregate raw rows in [cursor, frontier) into
completed 1-minute windows, recompute-style. frontier must be the
end of the last COMPLETE window (the caller computes it with the
grace). Returns the number of 1m windows written.