Struct SharedBufferBatch

pub struct SharedBufferBatch {
    pub(crate) inner: Arc<SharedBufferBatchInner>,
    pub table_id: TableId,
}

A write batch stored in the shared buffer.

Fields

inner: Arc<SharedBufferBatchInner>

table_id: TableId

Implementations

impl SharedBufferBatch

pub fn for_test( sorted_items: Vec<(TableKey<Bytes>, SharedBufferValue<Bytes>)>, epoch: HummockEpoch, table_id: TableId, ) -> Self

pub fn for_test_with_old_values( sorted_items: Vec<(TableKey<Bytes>, SharedBufferValue<Bytes>)>, old_values: Vec<Bytes>, epoch: HummockEpoch, table_id: TableId, ) -> Self

fn for_test_inner( sorted_items: Vec<(TableKey<Bytes>, SharedBufferValue<Bytes>)>, old_values: Option<Vec<Bytes>>, epoch: HummockEpoch, table_id: TableId, ) -> Self

pub fn measure_delete_range_size( batch_items: &[(Bound<Bytes>, Bound<Bytes>)], ) -> usize

pub fn measure_batch_size( batch_items: &[(TableKey<Bytes>, SharedBufferValue<Bytes>)], old_values: Option<&[Bytes]>, ) -> (usize, usize)

Return (total size, old value size or 0)

pub fn filter<R, B>(&self, table_id: TableId, table_key_range: &R) -> bool

where R: RangeBounds<TableKey<B>>, B: AsRef<[u8]>,

pub fn table_id(&self) -> TableId

pub fn min_epoch(&self) -> HummockEpoch

pub fn max_epoch(&self) -> HummockEpoch

pub fn key_count(&self) -> usize

pub fn value_count(&self) -> usize

pub fn has_old_value(&self) -> bool

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

pub fn range_exists(&self, table_key_range: &TableKeyRange) -> bool

pub fn into_directed_iter<D: HummockIteratorDirection, const IS_NEW_VALUE: bool>( self, ) -> SharedBufferBatchIterator<D, IS_NEW_VALUE>

pub fn into_old_value_iter(self) -> SharedBufferBatchIterator<Forward, false>

pub fn into_forward_iter(self) -> SharedBufferBatchIterator<Forward>

pub fn into_backward_iter(self) -> SharedBufferBatchIterator<Backward>

pub fn start_table_key(&self) -> TableKey<&[u8]>

pub fn end_table_key(&self) -> TableKey<&[u8]>

pub fn raw_largest_key(&self) -> &TableKey<Bytes>

pub fn start_user_key(&self) -> UserKey<&[u8]>

return inclusive left endpoint, which means that all data in this batch should be larger or equal than this key.

pub fn size(&self) -> usize

pub(crate) fn old_values(&self) -> Option<&SharedBufferBatchOldValues>

pub fn batch_id(&self) -> SharedBufferBatchId

pub fn epochs(&self) -> &Vec<HummockEpoch>

pub(crate) fn build_shared_buffer_batch( epoch: HummockEpoch, spill_offset: u16, sorted_items: Vec<(TableKey<Bytes>, SharedBufferValue<Bytes>)>, old_values: Option<SharedBufferBatchOldValues>, size: usize, table_id: TableId, tracker: Option<MemoryTracker>, ) -> Self

pub fn build_shared_buffer_batch_for_test( epoch: HummockEpoch, spill_offset: u16, sorted_items: Vec<(TableKey<Bytes>, SharedBufferValue<Bytes>)>, size: usize, table_id: TableId, ) -> Self

Trait Implementations

impl Clone for SharedBufferBatch

fn clone(&self) -> SharedBufferBatch

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SharedBufferBatch

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

Formats the value using the given formatter.