Struct AilakeFileReader 

pub struct AilakeFileReader { /* private fields */ }

Implementations

impl AilakeFileReader

pub fn new(bytes: Bytes, vector_column: &str, dim: u32) -> Self

pub fn ailk_offset(&self) -> AilakeResult<u64>

Returns the absolute byte offset of the primary AILK section. Reads ailake.footer_offset from the Parquet footer key-value metadata.

pub fn ailk_offset_for_column(&self, column: &str) -> AilakeResult<u64>

Returns the absolute byte offset of the AILK section for a named vector column.

For additional columns tries ailake.{column}.footer_offset first, then falls back to ailake.footer_offset (primary / single-column files).

pub fn is_ailake_file(&self) -> bool

Returns true if the file contains an embedded AILK section.

pub fn read_header(&self) -> AilakeResult<AilakeHeader>

Parse the 64-byte AI-Lake header from the embedded AILK section.

pub fn get_centroid(&self) -> AilakeResult<Centroid>

Read centroid + radius from the AILK section.

pub fn load_index(&self) -> AilakeResult<HnswIndex>

Load the HNSW index from the primary AILK section.

pub fn load_index_for_column(&self, column: &str) -> AilakeResult<HnswIndex>

Load the HNSW index for a specific vector column.

Works for both single-column files (falls back to primary AILK) and multi-column files written with AilakeFileWriter::write_multi.

pub fn load_any_index(&self) -> AilakeResult<AnyIndex>

Load primary index as AnyIndex, dispatching on header flags.

pub fn load_any_index_for_column(&self, column: &str) -> AilakeResult<AnyIndex>

Load index for a specific vector column as AnyIndex.

pub fn read_parquet(&self) -> AilakeResult<(RecordBatch, Vec<Vec<f32>>)>

Read the Parquet section (tabular data + decoded embeddings). The full file is valid Parquet; the AILK section is invisible to standard readers.

pub fn verify_integrity(&self) -> AilakeResult<()>

Verify the positional invariant: Parquet record_count == HNSW node_count.