Struct SharedBufferBatchInner

pub(crate) struct SharedBufferBatchInner {
    entries: Vec<SharedBufferKeyEntry>,
    new_values: Vec<(EpochWithGap, SharedBufferValue<Bytes>)>,
    old_values: Option<SharedBufferBatchOldValues>,
    epochs: Vec<HummockEpoch>,
    size: usize,
    _tracker: Option<MemoryTracker>,
    batch_id: SharedBufferBatchId,
}

Fields

entries: Vec<SharedBufferKeyEntry>

new_values: Vec<(EpochWithGap, SharedBufferValue<Bytes>)>

old_values: Option<SharedBufferBatchOldValues>

epochs: Vec<HummockEpoch>

The epochs of the data in batch, sorted in ascending order (old to new)

size: usize

Total size of all key-value items (excluding the epoch of value versions)

_tracker: Option<MemoryTracker>

batch_id: SharedBufferBatchId

For a batch created from multiple batches, this will be the largest batch id among input batches

Implementations

impl SharedBufferBatchInner

pub(crate) fn new( epoch: HummockEpoch, spill_offset: u16, payload: Vec<(TableKey<Bytes>, SharedBufferValue<Bytes>)>, old_values: Option<SharedBufferBatchOldValues>, size: usize, _tracker: Option<MemoryTracker>, ) -> Self

pub fn values(&self, i: usize) -> &[(EpochWithGap, SharedBufferValue<Bytes>)]

pub(crate) fn new_with_multi_epoch_batches( epochs: Vec<HummockEpoch>, entries: Vec<SharedBufferKeyEntry>, new_values: Vec<(EpochWithGap, SharedBufferValue<Bytes>)>, old_values: Option<SharedBufferBatchOldValues>, size: usize, imm_id: ImmId, tracker: Option<MemoryTracker>, ) -> Self

fn get_value( &self, table_key: TableKey<&[u8]>, read_epoch: HummockEpoch, ) -> Option<(HummockValue<Bytes>, EpochWithGap)>

Return None if cannot find a visible version Return HummockValue::Delete if the key has been deleted by some epoch <= read_epoch

Trait Implementations

impl Debug for SharedBufferBatchInner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for SharedBufferBatchInner

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.