Struct SstableIterator

pub struct SstableIterator {
    block_iter: Option<BlockIterator>,
    cur_idx: usize,
    preload_stream: Option<Box<dyn BlockStream>>,
    pub sst: TableHolder,
    preload_end_block_idx: usize,
    preload_retry_times: usize,
    sstable_store: SstableStoreRef,
    stats: StoreLocalStatistic,
    options: Arc<SstableIteratorReadOptions>,
}

Iterates on a sstable.

Fields

block_iter: Option<BlockIterator>

The iterator of the current block.

cur_idx: usize

Current block index.

preload_stream: Option<Box<dyn BlockStream>>

sst: TableHolder

Reference to the sst

preload_end_block_idx: usize

preload_retry_times: usize

sstable_store: SstableStoreRef

stats: StoreLocalStatistic

options: Arc<SstableIteratorReadOptions>

Implementations

impl SstableIterator

pub fn new( sstable: TableHolder, sstable_store: SstableStoreRef, options: Arc<SstableIteratorReadOptions>, ) -> Self

fn init_block_prefetch_range(&mut self, start_idx: usize)

async fn seek_idx( &mut self, idx: usize, seek_key: Option<FullKey<&[u8]>>, ) -> HummockResult<()>

Seeks to a block, and then seeks to the key if seek_key is given.

Trait Implementations

impl HummockIterator for SstableIterator

type Direction = Forward

async fn next(&mut self) -> HummockResult<()>

Moves a valid iterator to the next key.

fn key(&self) -> FullKey<&[u8]>

Retrieves the current key.

fn value(&self) -> HummockValue<&[u8]>

Retrieves the current value, decoded as HummockValue.

fn is_valid(&self) -> bool

Indicates whether the iterator can be used.

async fn rewind(&mut self) -> HummockResult<()>

Resets the position of the iterator.

async fn seek<'a>(&'a mut self, key: FullKey<&'a [u8]>) -> HummockResult<()>

Resets iterator and seeks to the first position where the key >= provided key, or key <= provided key if this is a backward iterator.

fn collect_local_statistic(&self, stats: &mut StoreLocalStatistic)

take local statistic info from iterator to report metrics.

fn value_meta(&self) -> ValueMeta

Returns value meta.

impl SstableIteratorType for SstableIterator

fn create( sstable: TableHolder, sstable_store: SstableStoreRef, options: Arc<SstableIteratorReadOptions>, ) -> Self