Method drain_for_partition

nodedb/src/engine/timeseries/o3_buffer.rs:67–79

Drain all rows targeting a specific partition (for merge). Returns the drained rows sorted by timestamp. Removes them from the buffer.

(&mut self, partition_start: i64)

    ///
    /// Returns the drained rows sorted by timestamp. Removes them from the buffer.
    pub fn drain_for_partition(&mut self, partition_start: i64) -> Vec<O3Row> {
        let mut drained = Vec::new();
        self.rows.retain(|r| {
            if r.target_partition_start == partition_start {
                drained.push(r.clone());
                false
            } else {
                true
            }
        });
        drained.sort_by_key(|r| r.timestamp_ms);
        drained
    }

    /// Dedup by (series_id, timestamp) — last-write-wins.
    ///