Struct AsyncSegmentReader 

pub struct AsyncSegmentReader { /* private fields */ }

Async segment reader with lazy loading

• Term dictionary: only index loaded, blocks loaded on-demand
• Postings: loaded on-demand per term via HTTP range requests
• Document store: only index loaded, blocks loaded on-demand via HTTP range requests

Implementations

impl AsyncSegmentReader

pub async fn open<D: Directory>( dir: &D, segment_id: SegmentId, schema: Arc<Schema>, doc_id_offset: DocId, cache_blocks: usize, ) -> Result<Self>

Open a segment with lazy loading

pub fn meta(&self) -> &SegmentMeta

pub fn num_docs(&self) -> u32

pub fn avg_field_len(&self, field: Field) -> f32

Get average field length for BM25F scoring

pub fn doc_id_offset(&self) -> DocId

pub fn schema(&self) -> &Schema

pub fn term_dict_stats(&self) -> SSTableStats

Get term dictionary stats for debugging

pub async fn get_postings( &self, field: Field, term: &[u8], ) -> Result<Option<BlockPostingList>>

Get posting list for a term (async - loads on demand)

For small posting lists (1-3 docs), the data is inlined in the term dictionary and no additional I/O is needed. For larger lists, reads from .post file.

pub async fn doc(&self, local_doc_id: DocId) -> Result<Option<Document>>

Get document by local doc_id (async - loads on demand)

pub async fn prefetch_terms( &self, field: Field, start_term: &[u8], end_term: &[u8], ) -> Result<()>

Prefetch term dictionary blocks for a key range

pub fn store_has_dict(&self) -> bool

Check if store uses dictionary compression (incompatible with raw merging)

pub fn store_raw_blocks(&self) -> Vec<RawStoreBlock>

Get raw store blocks for optimized merging

pub fn store_data_slice(&self) -> &LazyFileSlice

Get store data slice for raw block access

pub async fn all_terms(&self) -> Result<Vec<(Vec<u8>, TermInfo)>>

Get all terms from this segment (for merge)

pub async fn read_postings(&self, offset: u64, len: u32) -> Result<Vec<u8>>

Read raw posting bytes at offset