Type Alias mz_compute::typedefs::ErrAgent
source · pub type ErrAgent<T, R> = TraceAgent<ColKeySpine<DataflowError, T, R>>;
Aliased Type§
struct ErrAgent<T, R> {
trace: Rc<RefCell<TraceBox<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>>>>>,
queues: Weak<RefCell<Vec<Weak<(Activator, RefCell<VecDeque<TraceReplayInstruction<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>>>>>)>>>>,
logical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>> as TraceReader>::Time>,
physical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>> as TraceReader>::Time>,
temp_antichain: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>> as TraceReader>::Time>,
operator: OperatorInfo,
logging: Option<Logger<DifferentialEvent, usize>>,
}
Fields§
§trace: Rc<RefCell<TraceBox<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>>>>>
§queues: Weak<RefCell<Vec<Weak<(Activator, RefCell<VecDeque<TraceReplayInstruction<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>>>>>)>>>>
§logical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>> as TraceReader>::Time>
§physical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>> as TraceReader>::Time>
§temp_antichain: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((DataflowError, ()), T, R)>>>, ColumnatedMergeBatcher<DataflowError, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((DataflowError, ()), T, R)>>>> as TraceReader>::Time>
§operator: OperatorInfo
§logging: Option<Logger<DifferentialEvent, usize>>