Type Alias mz_compute::typedefs::KeyErrSpine

pub type KeyErrSpine<K, T, R> = ColValSpine<K, DataflowError, T, R>;

Aliased Type

struct KeyErrSpine<K, T, R> {
    operator: OperatorInfo,
    logger: Option<Logger<DifferentialEvent, usize>>,
    logical_frontier: Antichain<<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>> as BatchReader>::Time>,
    physical_frontier: Antichain<<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>> as BatchReader>::Time>,
    merging: Vec<MergeState<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>>>>,
    pending: Vec<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>>>,
    upper: Antichain<<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>> as BatchReader>::Time>,
    effort: usize,
    activator: Option<Activator>,
    exert_logic: Arc<dyn for<'a> Fn(Box<dyn Iterator<Item = (usize, usize, usize)> + 'a>) -> Option<usize> + Send + Sync>,
    phantom: PhantomData<(ColumnatedMergeBatcher<K, DataflowError, T, R>, RcBuilder<OrdValBuilder<TStack<((K, DataflowError), T, R)>>>)>,
}

Fields

operator: OperatorInfo

logger: Option<Logger<DifferentialEvent, usize>>

logical_frontier: Antichain<<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>> as BatchReader>::Time>

physical_frontier: Antichain<<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>> as BatchReader>::Time>

merging: Vec<MergeState<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>>>>

pending: Vec<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>>>

upper: Antichain<<Rc<OrdValBatch<TStack<((K, DataflowError), T, R)>>> as BatchReader>::Time>

effort: usize

activator: Option<Activator>

exert_logic: Arc<dyn for<'a> Fn(Box<dyn Iterator<Item = (usize, usize, usize)> + 'a>) -> Option<usize> + Send + Sync>

phantom: PhantomData<(ColumnatedMergeBatcher<K, DataflowError, T, R>, RcBuilder<OrdValBuilder<TStack<((K, DataflowError), T, R)>>>)>