Function mz_compute::logging::compute::construct

source ยท 
pub(super) fn construct<A: Allocate + 'static>(
    worker: &mut Worker<A>,
    config: &LoggingConfig,
    event_queue: EventQueue<Vec<(Duration, WorkerIdentifier, ComputeEvent)>>,
    shared_state: Rc<RefCell<SharedLoggingState>>,
) -> BTreeMap<LogVariant, LogCollection>
Expand description

Constructs the logging dataflow for compute logs.

Params

  • worker: The Timely worker hosting the log analysis dataflow.
  • config: Logging configuration.
  • event_queue: The source to read compute log events from.