Struct ProxyReduceTactic 

pub struct ProxyReduceTactic<T, Bk, K = u64> { /* private fields */ }

A proxy-space ReduceTactic: matches input and output records by key.

Implementations

impl<T, Bk, K> ProxyReduceTactic<T, Bk, K>

pub fn new(backend: Bk) -> Self

A tactic deferring all value semantics to backend.

pub fn with_key_batch_size(self, key_batch_size: usize) -> Self

Limit simultaneous sweeps independently of the backend’s presentation window.

Complete proxy keys stay together, including all real keys sharing a proxy. Sweep scratch is reused between groups within a retire. The bound does not limit a single key’s size, the presentation, or the output batch. Corrections remain batched, and emission still happens once per backend window. By default, all keys in the presentation can have live sweeps at once.

Trait Implementations

impl<T, B1, B2, Bk, K: Copy + Ord> ReduceTactic<T, B1, B2> for ProxyReduceTactic<T, Bk, K>

where T: Timestamp + Lattice, Bk: ProxyReduceBackend<T, B1, B2, Key = K>,

fn retire( &mut self, source_batches: Vec<B1>, output_batches: Vec<B2>, input_batches: Vec<B1>, lower: &Antichain<T>, upper: &Antichain<T>, held: &Antichain<T>, ) -> (Option<Span<T, B2>>, Antichain<T>)

Retire the interval [lower, upper), producing the output batch it informs.