Struct below_store::StoreWriter

pub struct StoreWriter { /* fields omitted */ }

The StoreWriter struct maintains state to put more data in the store. It keeps track of the index and data file it’s currently working on so in the common case it can just append data. When it rolls over to a new shard, it will recreate itself.

Implementations

impl StoreWriter

pub fn new<P: AsRef<Path>>(
    path: P,
    compress: bool,
    format: Format
) -> Result<Self>

Create a new StoreWriter that writes data to path directory. Data serialized with format.

If compress is set, dataframes are zstd compressed.

pub fn new_with_timestamp<P: AsRef<Path>>(
    path: P,
    timestamp: SystemTime,
    compress: bool,
    format: Format
) -> Result<Self>

pub fn put(
    &mut self,
    timestamp: SystemTime,
    data: &DataFrame,
    logger: Logger
) -> Result<()>

Store data with corresponding timestamp. Errors may be returned if file operations fail.

pub fn discard_earlier(
    &mut self,
    timestamp: SystemTime,
    logger: Logger
) -> Result<()>

Discard all data earlier than timestamp

We do not modify index and data files. We just look for files which can only contain earlier data and remove them.

Trait Implementations

impl Debug for StoreWriter

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

Formats the value using the given formatter.