Function construct

pub(super) fn construct<G: Scope<Timestamp = Timestamp>>(
    scope: G,
    config: &LoggingConfig,
    event_queue: EventQueue<Vec<(Duration, DifferentialEvent)>>,
    shared_state: Rc<RefCell<SharedLoggingState>>,
) -> Return

Constructs the logging dataflow fragment for differential logs.

Params

• scope: The Timely scope hosting the log analysis dataflow.
• config: Logging configuration
• event_queue: The source to read log events from.
• shared_state: Shared state across all logging dataflow fragments.