mito2::compaction::window

Function assign_files_to_time_windows

Source 
fn assign_files_to_time_windows<'a>(
    bucket_sec: i64,
    files: impl Iterator<Item = &'a FileHandle>,
) -> BTreeMap<i64, (i64, Vec<FileHandle>)>
Expand description

Assigns files to time windows. If file does not contain a time range in metadata, it will be assigned to a special bucket i64::MAX (normally no timestamp can be aligned to this bucket) so that all files without timestamp can be compacted together.