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.

Tries ailake.footer_offset from Parquet KV metadata first (files written by write() / write_multi()). Falls back to AilakeTrailer bootstrap for files produced by write_single_pass() / write_multi_single_pass().

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.

Resolution order:

1. ailake.{column}.footer_offset KV (extra columns in multi-column files)
2. ailake.footer_offset KV (primary column or single-column files)
3. AilakeTrailer scan (streaming / single-pass files without KV injection)

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 read_header_for_column(&self, column: &str) -> AilakeResult<AilakeHeader>

Parse the 64-byte AI-Lake header for a named vector column.

Uses ailake.{column}.footer_offset for extra columns and falls back to ailake.footer_offset for the primary column (single-column files).

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 load_fts_blob(&self) -> AilakeResult<Option<Bytes>>

Load the raw FTS blob from the AILK_FTS section, if present.

Returns Ok(None) when the file has no FTS section (opt-in feature). The returned bytes can be passed directly to ailake_fts::FtsSearcher::from_blob.

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

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