Struct differential_dataflow::collection::compact::CompactSession

pub struct CompactSession<'a, K: 'a, V: 'a> { /* fields omitted */ }

A session for adding one key's worth of updates.

Methods

impl<'a, K: 'a, V: 'a> CompactSession<'a, K, V>

fn new(compact: &'a mut Compact<K, V>) -> CompactSession<'a, K, V>

Allocates a new session.

fn push(&mut self, val: V, wgt: i32)

Adds an update for the key.

fn done(self, key: K)

Consumes the session and finalizes the updates.