Type Alias mz_compute::typedefs::ErrSpine
source · pub type ErrSpine<T, R> = ColKeySpine<DataflowError, T, R>;
Aliased Type§
struct ErrSpine<T, R> {
operator: OperatorInfo,
logger: Option<Logger<DifferentialEvent, usize>>,
logical_frontier: Antichain<<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>> as BatchReader>::Time>,
physical_frontier: Antichain<<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>> as BatchReader>::Time>,
merging: Vec<MergeState<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>>>,
pending: Vec<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>>,
upper: Antichain<<Rc<OrdKeyBatch<TStack<((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<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>)>,
}
Fields§
§operator: OperatorInfo
§logger: Option<Logger<DifferentialEvent, usize>>
§logical_frontier: Antichain<<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>> as BatchReader>::Time>
§physical_frontier: Antichain<<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>> as BatchReader>::Time>
§merging: Vec<MergeState<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>>>
§pending: Vec<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>>
§upper: Antichain<<Rc<OrdKeyBatch<TStack<((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<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>)>