Enum DeltaVariant 

pub enum DeltaVariant {
    RowBased(Arc<DeltaStore>),
    Columnar(Arc<ColumnarDelta>),
}

Delta Store variant — supports both row-based and columnar implementations.

Variants

RowBased(Arc<DeltaStore>)

Columnar(Arc<ColumnarDelta>)

Implementations

impl DeltaVariant

pub fn should_flush(&self) -> bool

pub fn entry_count(&self) -> usize

pub fn drain_all(&self) -> Vec<(String, Vec<(Vec<u8>, Vec<u8>)>)>

Drain all data from the store. Returns table→entries mapping for flushing to WOS.

Trait Implementations

impl StorageBackend for DeltaVariant

fn insert(&self, table: &str, key: &[u8], value: &[u8]) -> DbxResult<()>

Insert a key-value pair.

fn insert_batch( &self, table: &str, rows: Vec<(Vec<u8>, Vec<u8>)>, ) -> DbxResult<()>

Insert multiple key-value pairs in a batch (optimized).

fn get(&self, table: &str, key: &[u8]) -> DbxResult<Option<Vec<u8>>>

Get a value by key.

fn delete(&self, table: &str, key: &[u8]) -> DbxResult<bool>

Delete a key-value pair.

fn scan<R: RangeBounds<Vec<u8>> + Clone>( &self, table: &str, range: R, ) -> DbxResult<Vec<(Vec<u8>, Vec<u8>)>>

Scan a range of keys.

fn scan_one<R: RangeBounds<Vec<u8>> + Clone>( &self, table: &str, range: R, ) -> DbxResult<Option<(Vec<u8>, Vec<u8>)>>

Scan a single key-value pair in a range (optimized).

fn flush(&self) -> DbxResult<()>

Flush any buffered data to durable storage.

fn count(&self, table: &str) -> DbxResult<usize>

Return the number of keys in the given table.

fn table_names(&self) -> DbxResult<Vec<String>>

Return all table names managed by this backend.