Struct ConcatIteratorInner

pub struct ConcatIteratorInner<TI: SstableIteratorType> {
    sstable_iter: Option<TI>,
    cur_idx: usize,
    tables: Vec<SstableInfo>,
    sstable_store: SstableStoreRef,
    stats: StoreLocalStatistic,
    read_options: Arc<SstableIteratorReadOptions>,
}

Served as the concrete implementation of ConcatIterator and BackwardConcatIterator.

Fields

sstable_iter: Option<TI>

The iterator of the current table.

cur_idx: usize

Current table index.

tables: Vec<SstableInfo>

All non-overlapping tables.

sstable_store: SstableStoreRef

stats: StoreLocalStatistic

read_options: Arc<SstableIteratorReadOptions>

Implementations

impl<TI: SstableIteratorType> ConcatIteratorInner<TI>

pub fn new( tables: Vec<SstableInfo>, sstable_store: SstableStoreRef, read_options: Arc<SstableIteratorReadOptions>, ) -> Self

Caller should make sure that tables are non-overlapping, arranged in ascending order when it serves as a forward iterator, and arranged in descending order when it serves as a backward iterator.

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

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

Trait Implementations

impl<TI: SstableIteratorType> HummockIterator for ConcatIteratorInner<TI>

type Direction = <TI as HummockIterator>::Direction

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.