Module reader 

Structs

CompactionSstReaderBuilder 🔒

Builders to create [BoxedRecordBatchStream] for compaction.

Constants

MAX_CONCURRENT_METADATA_READS 🔒

Max number of input footers read at the same time.

MERGED_BATCH_CHANNEL_SIZE 🔒

Number of merged batches buffered between the merge task and the SST writer.

Functions

spawn_merge 🔒

Reads and merges source on a separate task, so the SST writer can encode merged batches while the next ones are being read and merged.

time_range_to_predicate 🔒

Converts time range to predicates so that rows outside the range will be filtered.

ts_to_lit 🔒