mz_compute::logging::reachability

Function construct

Source
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 configuration
  • event_queue: The source to read log events from.