Struct KeyAligner 

pub struct KeyAligner { /* private fields */ }

Decodes opaque lookup keys and realigns fetched rows to the input key order.

Implementations

impl KeyAligner

pub fn new( pk_sort_fields: Vec<SortField>, pk_columns: Vec<String>, ) -> Result<Self, LookupError>

Build an aligner from the primary-key sort fields and column names (same order).

Errors

Returns LookupError::Internal if the key is empty or the converter cannot be built for the given sort fields.

pub fn pk_columns(&self) -> &[String]

The primary-key column names, in key order.

pub fn decode_keys(&self, keys: &[&[u8]]) -> Result<Vec<ArrayRef>, LookupError>

Decode opaque key bytes into the primary-key columns (column-major: one array per PK column, each keys.len() long) for building a source filter.

Errors

Returns LookupError::Internal if the bytes cannot be decoded.

pub fn align( &self, keys: &[&[u8]], fetched: &[RecordBatch], ) -> Result<Vec<Option<RecordBatch>>, LookupError>

Realign fetched rows to the input key order. Each fetched row is matched to its key by re-encoding its PK columns; the first row wins per key, duplicate input keys each resolve to their own single-row slice, and misses are None.

Errors

Returns LookupError::Internal if a PK column is absent from a fetched batch or cannot be re-encoded.