Struct SharedBufferBatchIterator

pub struct SharedBufferBatchIterator<D: HummockIteratorDirection, const IS_NEW_VALUE: bool = true> {
    inner: Arc<SharedBufferBatchInner>,
    current_entry_idx: usize,
    current_value_idx: usize,
    value_end_offset: usize,
    table_id: TableId,
    _phantom: PhantomData<D>,
}

Iterate all the items in the shared buffer batch If there are multiple versions of a key, the iterator will return all versions

Fields

inner: Arc<SharedBufferBatchInner>

current_entry_idx: usize

The index of the current entry in the payload

current_value_idx: usize

The index of current value

value_end_offset: usize

The exclusive end offset of the value index of current key.

table_id: TableId

_phantom: PhantomData<D>

Implementations

impl<D: HummockIteratorDirection, const IS_NEW_VALUE: bool> SharedBufferBatchIterator<D, IS_NEW_VALUE>

pub(crate) fn new(inner: Arc<SharedBufferBatchInner>, table_id: TableId) -> Self

fn is_valid_entry_idx(&self) -> bool

fn advance_to_next_entry(&mut self)

fn reset_value_idx(&mut self)

fn get_value_end_offset(&self) -> usize

fn assert_valid_idx(&self)

fn advance_to_next_value(&mut self)

fn advance_until_valid_old_value(&mut self)

impl SharedBufferBatchIterator<Forward>

pub(crate) fn advance_to_next_key(&mut self)

pub(crate) fn current_key_entry(&self) -> SharedBufferVersionedEntryRef<'_>

Trait Implementations

impl<D: HummockIteratorDirection, const IS_NEW_VALUE: bool> HummockIterator for SharedBufferBatchIterator<D, IS_NEW_VALUE>

type Direction = D

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.