pub(super) fn construct<G: Scope<Timestamp = Timestamp>>(
scope: G,
config: &LoggingConfig,
event_queue: EventQueue<Column<(Duration, (usize, Vec<(usize, usize, bool, Timestamp, Diff)>))>, 3>,
) -> Return
Expand description
Constructs the logging dataflow fragment for reachability logs.
Params
scope
: The Timely scope hosting the log analysis dataflow.config
: Logging configurationevent_queue
: The source to read log events from.