Struct LocalHummockFlushedSnapshotReader

pub struct LocalHummockFlushedSnapshotReader {
    table_id: TableId,
    read_version: HummockReadVersionRef,
    hummock_version_reader: HummockVersionReader,
}

Fields

table_id: TableId

read_version: HummockReadVersionRef

hummock_version_reader: HummockVersionReader

Implementations

impl LocalHummockFlushedSnapshotReader

async fn get_flushed( hummock_version_reader: &HummockVersionReader, read_version: &HummockReadVersionRef, table_key: TableKey<Bytes>, epoch: u64, read_options: ReadOptions, ) -> StorageResult<Option<StateStoreKeyedRow>>

async fn iter_flushed( &self, table_key_range: TableKeyRange, epoch: u64, read_options: ReadOptions, ) -> StorageResult<HummockStorageIterator>

async fn rev_iter_flushed( &self, table_key_range: TableKeyRange, epoch: u64, read_options: ReadOptions, ) -> StorageResult<HummockStorageRevIterator>

Trait Implementations

impl Clone for LocalHummockFlushedSnapshotReader

fn clone(&self) -> LocalHummockFlushedSnapshotReader

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl StateStoreRead for LocalHummockFlushedSnapshotReader

type Iter = HummockStorageIteratorInner<'static>

type RevIter = HummockStorageRevIteratorInner<'static>

fn get_keyed_row( &self, key: TableKey<Bytes>, epoch: u64, read_options: ReadOptions, ) -> impl Future<Output = StorageResult<Option<StateStoreKeyedRow>>> + Send + '_

Point gets a value from the state store. The result is based on a snapshot corresponding to the given epoch. Both full key and the value are returned.

fn iter( &self, key_range: TableKeyRange, epoch: u64, read_options: ReadOptions, ) -> impl Future<Output = StorageResult<Self::Iter>> + '_

Opens and returns an iterator for given prefix_hint and full_key_range Internally, prefix_hint will be used to for checking bloom_filter and full_key_range used for iter. (if the prefix_hint not None, it should be be included in key_range) The returned iterator will iterate data based on a snapshot corresponding to the given epoch.

fn rev_iter( &self, key_range: TableKeyRange, epoch: u64, read_options: ReadOptions, ) -> impl Future<Output = StorageResult<Self::RevIter>> + '_

fn get( &self, key: TableKey<Bytes>, epoch: u64, read_options: ReadOptions, ) -> impl StorageFuture<'_, Option<Bytes>>

Point gets a value from the state store. The result is based on a snapshot corresponding to the given epoch. Only the value is returned.