Trait Memtable

Source

pub trait Memtable:
    Send
    + Sync
    + Debug {
    // Required methods
    fn id(&self) -> MemtableId;
    fn write(&self, kvs: &KeyValues) -> Result<()>;
    fn write_one(&self, key_value: KeyValue<'_>) -> Result<()>;
    fn write_bulk(&self, part: BulkPart) -> Result<()>;
    fn iter(
        &self,
        projection: Option<&[ColumnId]>,
        predicate: Option<Predicate>,
        sequence: Option<SequenceNumber>,
    ) -> Result<BoxedBatchIterator>;
    fn ranges(
        &self,
        projection: Option<&[ColumnId]>,
        predicate: PredicateGroup,
        sequence: Option<SequenceNumber>,
    ) -> MemtableRanges;
    fn is_empty(&self) -> bool;
    fn freeze(&self) -> Result<()>;
    fn stats(&self) -> MemtableStats;
    fn fork(&self, id: MemtableId, metadata: &RegionMetadataRef) -> MemtableRef;
}

Expand description

In memory write buffer.

Required Methods§

Source

fn id(&self) -> MemtableId

Returns the id of this memtable.

Source

fn write(&self, kvs: &KeyValues) -> Result<()>

Writes key values into the memtable.

Source

fn write_one(&self, key_value: KeyValue<'_>) -> Result<()>

Writes one key value pair into the memtable.

Source

fn write_bulk(&self, part: BulkPart) -> Result<()>

Writes an encoded batch of into memtable.

Source

fn iter( &self, projection: Option<&[ColumnId]>, predicate: Option<Predicate>, sequence: Option<SequenceNumber>, ) -> Result<BoxedBatchIterator>

Scans the memtable. projection selects columns to read, None means reading all columns. filters are the predicates to be pushed down to memtable.

Source