Function mz_compute::logging::materialized::construct

pub fn construct<A: Allocate>(
    worker: &mut Worker<A>, 
    config: &LoggingConfig, 
    compute: Rc<EventLink<Timestamp, (Duration, WorkerIdentifier, ComputeEvent)>>, 
    activator: RcActivator
) -> HashMap<LogVariant, (TraceAgent<OrdValSpine<Row, Row, Timestamp, Diff, usize>>, Rc<dyn Any>)>

Constructs the logging dataflow for materialized logs.

Params

• worker: The Timely worker hosting the log analysis dataflow.
• config: Logging configuration
• compute: The source to read compute 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.