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.

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 🔒

LastRowCacheReader 🔒

Last row reader that returns the cached last rows for row group.

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.

RowGroupLastRowReader 🔒

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.

RowGroupLastRowCachedReader 🔒

Cached last row reader for specific row group. If the last rows for current row group are already cached, this reader returns the cached value. If cache misses, RowGroupLastRowReader reads last rows from row group and updates the cache upon finish.

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.

push_yielded_batches 🔒

Push last row into yielded_batches.