Type Alias mz_compute::typedefs::KeyAgent

pub type KeyAgent<K, T, R> = TraceAgent<ColKeySpine<K, T, R>>;

Aliased Type

struct KeyAgent<K, T, R> {
    trace: Rc<RefCell<TraceBox<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>>>>>,
    queues: Weak<RefCell<Vec<Weak<(Activator, RefCell<VecDeque<TraceReplayInstruction<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>>>>>)>>>>,
    logical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>> as TraceReader>::Time>,
    physical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>> as TraceReader>::Time>,
    temp_antichain: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>> as TraceReader>::Time>,
    operator: OperatorInfo,
    logging: Option<Logger<DifferentialEvent, usize>>,
}

Fields

trace: Rc<RefCell<TraceBox<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>>>>>

queues: Weak<RefCell<Vec<Weak<(Activator, RefCell<VecDeque<TraceReplayInstruction<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>>>>>)>>>>

logical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>> as TraceReader>::Time>

physical_compaction: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>> as TraceReader>::Time>

temp_antichain: Antichain<<Spine<Rc<OrdKeyBatch<TStack<((K, ()), T, R)>>>, ColumnatedMergeBatcher<K, (), T, R>, RcBuilder<OrdKeyBuilder<TStack<((K, ()), T, R)>>>> as TraceReader>::Time>

operator: OperatorInfo

logging: Option<Logger<DifferentialEvent, usize>>