Struct MemoryDecayJob 

pub struct MemoryDecayJob {
    pub decay_lambda: f32,
    /* private fields */
}

Periodic job that updates recency_weight for all records in a table.

The weight decays exponentially with age: recency_weight = exp(-lambda * days_since_last_access)

Where days_since_last_access is computed from the last_accessed_at column (ISO 8601 string or Unix timestamp string in the record).

Usage

let job = MemoryDecayJob::new(catalog, store, policy, lambda: 0.1);
let updated = job.run(&table).await?;
println!("{updated} files updated");

Fields

decay_lambda: f32

Exponential decay rate. Higher lambda → faster decay. Typical values: 0.05 (slow) to 0.5 (aggressive).

Implementations

impl MemoryDecayJob

pub fn new( catalog: Arc<dyn CatalogProvider>, store: Arc<dyn Store>, policy: VectorStoragePolicy, decay_lambda: f32, ) -> Self

pub async fn run(&self, table: &TableIdent) -> AilakeResult<usize>

Run decay update across all data files in the table’s current snapshot.

Returns the number of files that were rewritten (files missing the last_accessed_at column are skipped).