Function dataflow::logging::reachability::construct

pub fn construct<A: Allocate>(
    worker: &mut Worker<A>, 
    config: &LoggingConfig, 
    linked: Rc<EventLink<Timestamp, (Duration, WorkerIdentifier, (Vec<usize>, Vec<(usize, usize, bool, Option<Timestamp>, isize)>))>>, 
    activator: RcActivator
) -> HashMap<LogVariant, TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>>

Constructs the logging dataflow for reachability logs.

Params

• worker: The Timely worker hosting the log analysis dataflow.
• config: Logging configuration
• linked: The source to read log events from.
• activator: A handle to acknowledge activations.

Returns a map from log variant to a tuple of a trace handle and a permutation to reconstruct the original rows.