risingwave_storage::store

Trait StateStoreReadExt

source 
pub trait StateStoreReadExt: StaticSendSync {
    // Required method
    fn scan(
        &self,
        key_range: TableKeyRange,
        epoch: u64,
        limit: Option<usize>,
        read_options: ReadOptions,
    ) -> impl Future<Output = StorageResult<Vec<StateStoreKeyedRow>>> + Send + '_;
}

Required Methods§

source

fn scan( &self, key_range: TableKeyRange, epoch: u64, limit: Option<usize>, read_options: ReadOptions, ) -> impl Future<Output = StorageResult<Vec<StateStoreKeyedRow>>> + Send + '_

Scans limit number of keys from a key range. If limit is None, scans all elements. Internally, prefix_hint will be used to for checking bloom_filter and full_key_range used for iter. The result is based on a snapshot corresponding to the given epoch.

By default, this simply calls StateStore::iter to fetch elements.

Object Safety§

This trait is not object safe.

Implementors§