Function mz_compute::logging::reachability::construct
source · pub(super) fn construct<A: Allocate>(
worker: &mut Worker<A>,
config: &LoggingConfig,
event_queue: EventQueue<(Vec<usize>, Vec<(usize, usize, bool, Option<Timestamp>, Diff)>)>
) -> BTreeMap<LogVariant, (TraceAgent<Spine<Rc<OrdValBatch<RowRowLayout<((Row, Row), Timestamp, Diff)>>>, ColumnatedMergeBatcher<Row, Row, Timestamp, Diff>, RcBuilder<OrdValBuilder<RowRowLayout<((Row, Row), Timestamp, Diff)>>>>>, Rc<dyn Any>)>
Expand description
Constructs the logging dataflow for reachability logs.
Params
worker
: The Timely worker hosting the log analysis dataflow.config
: Logging configurationevent_queue
: The source to read log events from.
Returns a map from log variant to a tuple of a trace handle and a permutation to reconstruct the original rows.