Module compact

Structs

CompactConfig

A snapshot of dynamic configs to make it easier to reason about an individual run of compaction.

CompactReq

A request for compaction.

CompactRes

A response from compaction.

Compactor

A service for performing physical and logical compaction.

RunLocation

A location in a spine, used to identify the Run that a batch belongs to. If the Run is not known, the RunId is None.

Timings 🔒

Constants

COMPACTION_CHECK_PROCESS_FLAG 🔒

COMPACTION_MINIMUM_TIMEOUT 🔒

In Compactor::compact_and_apply_background, the minimum amount of time to allow a compaction request to run before timing it out. A request may be given a timeout greater than this value depending on the inputs’ size

COMPACTION_USE_MOST_RECENT_SCHEMA 🔒

Functions

input_id_range 🔒

Create a [CompactionInput::IdRange] from a set of SpineIds.