Function construct

pub(super) fn construct<S: Scheduler + 'static, G: Scope<Timestamp = Timestamp>>(
    scope: G,
    scheduler: S,
    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.