Trait mz_compute::logging::compute::LogDataflowErrors

pub(crate) trait LogDataflowErrors {
    // Required method
    fn log_dataflow_errors(
        self,
        logger: Logger<ComputeEvent, WorkerIdentifier>,
        export_id: GlobalId
    ) -> Self;
}

Extension trait to attach ComputeEvent::DataflowError logging operators to collections and batch streams.

Required Methods

fn log_dataflow_errors( self, logger: Logger<ComputeEvent, WorkerIdentifier>, export_id: GlobalId ) -> Self

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<G, B> LogDataflowErrors for Stream<G, B>where G: Scope, B: BatchReader<Diff = Diff> + Clone + 'static,

fn log_dataflow_errors( self, logger: Logger<ComputeEvent, WorkerIdentifier>, export_id: GlobalId ) -> Self

impl<G, D> LogDataflowErrors for Collection<G, D, Diff>where G: Scope, D: Data,

fn log_dataflow_errors( self, logger: Logger<ComputeEvent, WorkerIdentifier>, export_id: GlobalId ) -> Self

Implementors