Struct MemTableAccessor

pub struct MemTableAccessor<A: AllocatorTrait> { /* private fields */ }

A collection of MemTables.

Internally, they are stored in multiple HashMaps, which are indexed by hashed region IDs.

Implementations

impl MemTableAccessor<DummyAllocator>

pub fn new(global_stats: Arc<GlobalStats>) -> MemTableAccessor<DummyAllocator>

impl MemTableAccessor<DummyAllocator>

pub fn memory_usage(&self) -> usize

impl<A: AllocatorTrait> MemTableAccessor<A>

pub fn new_with_allocator( global_stats: Arc<GlobalStats>, allocator: A, ) -> MemTableAccessor<A>

pub fn get_or_insert(&self, raft_group_id: u64) -> Arc<RwLock<MemTable<A>>>

pub fn get(&self, raft_group_id: u64) -> Option<Arc<RwLock<MemTable<A>>>>

pub fn insert(&self, raft_group_id: u64, memtable: Arc<RwLock<MemTable<A>>>)

pub fn remove(&self, raft_group_id: u64, record_tombstone: bool)

pub fn fold<B, F: Fn(B, &MemTable<A>) -> B>(&self, init: B, fold: F) -> B

pub fn collect<F: FnMut(&MemTable<A>) -> bool>( &self, condition: F, ) -> Vec<Arc<RwLock<MemTable<A>>>>

pub fn take_cleaned_region_logs(&self) -> LogBatch

Returns a LogBatch containing Command::Cleans of all deleted MemTables. The records for these tables will be cleaned up afterwards.

pub fn is_empty(&self) -> bool

Returns true if it does not contains any memtable.

pub fn merge_newer_neighbor(&self, rhs: Self)

Merges with a newer neighbor MemTableAccessor.

This method is only used for recovery.

pub fn merge_append_table(&self, rhs: Self)

Merges with a MemTableAccessor that contains only append data. Assumes self contains all rewritten data.

This method is only used for recovery.

pub fn apply_append_writes(&self, log_items: impl Iterator<Item = LogItem>)

Applies changes from log items that have been written to append queue.

pub fn replay_append_writes(&self, log_items: impl Iterator<Item = LogItem>)

Applies changes from log items that are replayed from a append queue. Assumes it haven’t applied any rewrite data.

This method is only used for recovery.

pub fn apply_rewrite_writes( &self, log_items: impl Iterator<Item = LogItem>, watermark: Option<FileSeq>, new_file: FileSeq, )

Applies changes from log items that have been written to rewrite queue.

pub fn replay_rewrite_writes(&self, log_items: impl Iterator<Item = LogItem>)

Applies changes from log items that are replayed from a rewrite queue. Assumes it haven’t applied any append data.

This method is only used for recovery.

pub fn apply_rewrite_atomic_group( &self, raft: u64, start: FileSeq, end: FileSeq, )

Trait Implementations

impl<A: Clone + AllocatorTrait> Clone for MemTableAccessor<A>

fn clone(&self) -> MemTableAccessor<A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.