Module last_row 

Utilities to read the last row of each time series.

Structs

BatchBuffer 🔒

Buffer that accumulates small RecordBatches and tracks total row count.

FlatLastRowCacheReader 🔒

Iterates over cached flat last rows.

FlatLastRowReader 🔒

Reader that keeps only the last row of each time series from a flat RecordBatch stream. Assumes input is sorted, deduped, and contains no delete operations.

FlatLastTimestampSelector 🔒

Selects the last-timestamp rows per primary key from flat RecordBatch.

FlatRowGroupLastRowReader 🔒

Reads last rows from a flat format row group and caches the results.

LastKeyState 🔒

LastRowReader 🔒

Reader to keep the last row for each time series. It assumes that batches from the input reader are

LastRowSelector

Common struct that selects only the last row of each time series.

Enums

FlatRowGroupLastRowCachedReader 🔒

Cached last row reader for flat format row group. If the last rows are already cached (as flat RecordBatch), returns cached values. Otherwise, reads from the row group, selects last rows, and updates the cache.

Functions

last_timestamp_start 🔒

Finds the start index of rows sharing the last (maximum) timestamp within the range [range_start, range_end).

primary_key_bytes_at 🔒

Gets the primary key bytes at index from the primary key dictionary column.