diskann_disk::storage::disk_index_reader

Struct DiskIndexReader

pub struct DiskIndexReader { /* private fields */ }

Expand description

This struct is used by the DiskIndexSearcher to read the index data from storage. Noted that the index data here is different from index graph, It includes the PQ data, pivot table, and the warmup query data. The Storage acts as a provider to read the data from storage system. The storage provider should be provided as a generic type and be specified by the caller when it initializes the DiskIndexSearcher.

DiskIndexReader

Struct DiskIndexReader Copy item path

Implementations§

impl DiskIndexReader

pub fn new<Storage: StorageReadProvider>( pq_pivot_path: String, pq_compressed_data_path: String, storage_provider: &Storage, ) -> ANNResult<Self>

pub fn get_pq_data(&self) -> Arc<PQData>

pub fn get_num_points(&self) -> usize

Auto Trait Implementations§

impl Freeze for DiskIndexReader

impl RefUnwindSafe for DiskIndexReader

impl Send for DiskIndexReader

impl Sync for DiskIndexReader

impl Unpin for DiskIndexReader

impl UnsafeUnpin for DiskIndexReader

impl UnwindSafe for DiskIndexReader

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> AsyncFriendly for Twhere T: Send + Sync + 'static,

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> ByRef<T> for T

fn by_ref(&self) -> &T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct DiskIndexReader

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> AsyncFriendly for T
where T: Send + Sync + 'static,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,