Module write_partition 

Add or remove view partitions

Structs

PartitionRowSet

A set of rows for a partition, along with their time range.

RowSetTrackingResult

Result of write_rows_and_track_times: the partition’s event time range, alongside the folded max_sort_key_time. pub because write_rows_and_track_times is itself pub and is called from rust/analytics/tests/, which compiles as an external crate.

Enums

RetireMatch

Which SQL predicate retire_partitions uses to find partitions to replace.

Functions

add_file_for_cleanup

Adds a file to the temporary_files table for cleanup.

insert_partition

Inserts a partition into lakehouse_partitions, retiring whatever retire_match says it replaces first.

retire_expired_partitions

retire_partitions

Retires partitions from the active set.

write_partition_from_rows

Writes a partition to a Parquet file from a stream of PartitionRowSets.

write_rows_and_track_times

Writes rows from the stream and tracks event time ranges.