Struct DecodedPrimaryKeys 

pub struct DecodedPrimaryKeys {
    inner: DecodedKeysInner,
    keys_array: UInt32Array,
    pk_offsets: SparseOffsetsCache,
    value_buf: Vec<u8>,
}

Holds decoded primary key values for unique keys and their indices.

Fields

inner: DecodedKeysInner

keys_array: UInt32Array

Prebuilt keys array for creating dictionary arrays.

pk_offsets: SparseOffsetsCache

Scratch offsets shared when extracting sparse tag values.

value_buf: Vec<u8>

Reusable buffer for extracting sparse tag values.

Implementations

impl DecodedPrimaryKeys

pub fn get_tag_column( &mut self, column_id: ColumnId, pk_index: Option<usize>, column_type: &ConcreteDataType, ) -> Result<ArrayRef>

Gets a tag column array by column id and data type.

For sparse encoding, extracts the column lazily from the encoded keys. For dense encoding, uses pk_index to decode only the requested field.

pub fn get_dense_tag_columns(&self) -> Result<Vec<ArrayRef>>

Materializes all Dense tags in source-schema order with one sequential traversal per key. Values are consumed immediately by their Arrow builders.

pub fn get_sparse_tag_columns( &mut self, columns: &[(ColumnId, ConcreteDataType)], ) -> Result<Vec<ArrayRef>>

Gets multiple sparse tag column arrays in one pass over the distinct keys, sharing each key’s offset discovery between the columns.

Must only be called for sparse primary keys. Columns hold their values in the order of columns, whose entries are tag column ids and data types.