Struct ConcatSstableIterator

pub struct ConcatSstableIterator {
    key_range: KeyRange,
    sstable_iter: Option<SstableStreamIterator>,
    cur_idx: usize,
    sstables: Vec<SstableInfo>,
    existing_table_ids: HashSet<StateTableId>,
    sstable_store: SstableStoreRef,
    stats: StoreLocalStatistic,
    task_progress: Arc<TaskProgress>,
    max_io_retry_times: usize,
}

Iterates over the KV-pairs of a given list of SSTs. The key-ranges of these SSTs are assumed to be consecutive and non-overlapping.

Fields

key_range: KeyRange

CAUTION: key_range is used for optimization. It doesn’t guarantee value returned by the iterator is in this range.

sstable_iter: Option<SstableStreamIterator>

The iterator of the current table.

cur_idx: usize

Current table index.

sstables: Vec<SstableInfo>

All non-overlapping tables.

existing_table_ids: HashSet<StateTableId>

sstable_store: SstableStoreRef

stats: StoreLocalStatistic

task_progress: Arc<TaskProgress>

max_io_retry_times: usize

Implementations

impl ConcatSstableIterator

pub fn new( existing_table_ids: Vec<StateTableId>, sst_infos: Vec<SstableInfo>, key_range: KeyRange, sstable_store: SstableStoreRef, task_progress: Arc<TaskProgress>, max_io_retry_times: usize, ) -> 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<()>

Resets the iterator, loads the specified SST, and seeks in that SST to seek_key if given.

Trait Implementations

impl HummockIterator for ConcatSstableIterator

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

Resets the iterator and seeks to the first position where the stored key >= key.

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.

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.