Struct SkipWatermarkIterator

pub struct SkipWatermarkIterator<I> {
    inner: I,
    state: SkipWatermarkState,
    skipped_entry_table_stats: TableStatsMap,
    last_table_id: Option<u32>,
    last_table_stats: TableStats,
}

Fields

inner: I

state: SkipWatermarkState

skipped_entry_table_stats: TableStatsMap

The stats of skipped key-value pairs for each table.

last_table_id: Option<u32>

The id of table currently undergoing processing.

last_table_stats: TableStats

The stats of table currently undergoing processing.

Implementations

impl<I: HummockIterator<Direction = Forward>> SkipWatermarkIterator<I>

pub fn new(inner: I, watermarks: BTreeMap<TableId, ReadTableWatermark>) -> Self

pub fn from_safe_epoch_watermarks( inner: I, safe_epoch_watermarks: &BTreeMap<u32, TableWatermarks>, ) -> Self

fn reset_watermark(&mut self)

fn reset_skipped_entry_table_stats(&mut self)

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

Advance the key until iterator invalid or the current key will not be filtered by the latest watermark. Calling this method should ensure that the first remaining watermark has been advanced to the current key.

Return a flag indicating whether should later advance the watermark.

fn add_last_table_stats(&mut self)

Trait Implementations

impl<I: HummockIterator<Direction = Forward>> HummockIterator for SkipWatermarkIterator<I>

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.