Module twcs 

Structs

Candidate 🔒

Metrics of a candidate compaction input, accumulated incrementally as the candidate interval expands one file at a time.

CandidateScore 🔒

Score of a candidate compaction input. Higher is better: first by the predicted net file count reduction, then by the number of files participating in an overlap, then by smaller input bytes.

OrderedFile 🔒

TwcsPicker

TwcsPicker picks files of which the max timestamp are in the same time window as compaction candidates.

Window 🔒

Constants

DEFAULT_MAX_INPUT_FILES 🔒

Default maximum number of input SST files in one compaction input.

LEVEL_COMPACTED 🔒

MAX_INPUT_FILES_ENV 🔒

MAX_L1_L0_ROW_RATIO 🔒

A mixed L0/L1 compaction may rewrite at most this many L1 rows per L0 row.

Statics

MAX_INPUT_FILES 🔒

Maximum number of input SST files in one compaction input. Configurable via MAX_INPUT_FILES_ENV.

Functions

assign_to_windows 🔒

Assigns files to windows with predefined window size (in seconds) by their max timestamps.

find_latest_window_in_seconds 🔒

Finds the latest active writing window among all files. Returns None when there are no files or all files are corrupted.

log_pick_result 🔒

ordered_files 🔒

Flattens sorted runs into files ordered by (start asc, end desc), breaking ties by run and position to keep the order deterministic.

parse_max_input_files 🔒

pick_candidate_files 🔒

pick_count_first 🔒

Picks a contiguous (in global time order) interval of files to compact.

pick_count_first_where 🔒

pick_mixed_count_first 🔒

selected_overlaps_unselected 🔒

time_window_intersects_range 🔒

window_has_overlap 🔒