Function construct 

pub(super) fn construct<'scope>(
    scope: Scope<'scope, Timestamp>,
    activations: Rc<RefCell<Activations>>,
    config: &LoggingConfig,
    event_queue: EventQueue<Column<(Duration, ComputeEvent)>>,
    shared_state: Rc<RefCell<SharedLoggingState>>,
) -> Return

Constructs the logging dataflow fragment for compute logs.

Params

• scope: The Timely scope hosting the log analysis dataflow.
• scheduler: The timely scheduler to obtainer activators.
• config: Logging configuration.
• event_queue: The source to read compute log events from.
• compute_event_streams: Additional compute event streams to absorb.
• shared_state: Shared state between logging dataflow fragments.