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.
InactiveWindowPick 🔒: Picks compaction inputs for an inactive window.
OrderedFile 🔒
TwcsPicker: TwcsPicker picks files of which the max timestamp are in the same time window as compaction candidates.
Window 🔒
WindowOutputContext 🔒
WindowPickContext 🔒

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.
PICK_PHASES 🔒

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

assign_to_windows 🔒: Assigns files to windows with predefined window size (in seconds) by their max timestamps.
find_active_window_by_sequence 🔒: Finds the active window from the file with the highest sequence number.
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.
is_balanced_candidate 🔒
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_inactive_window_files 🔒
pick_l1_candidate_files 🔒
pick_l1_file_reduction 🔒
pick_l1_overlap_only 🔒
pick_mixed_within_budget 🔒: Mixed-level fallback for inactive windows: bypasses the balance checks but bounds the total rewrite to the output file budget.
pick_unbalanced_count_first 🔒: Last-resort pick for inactive windows with no balance requirement at all. Callers must only pass single-level (L0) files so the rewrite stays bounded by their bytes.
selected_overlaps_unselected 🔒
time_window_intersects_range 🔒
window_has_overlap 🔒