mz_compute::logging::compute

Trait LogDataflowErrors

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

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

Required Methods§

Source

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

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

Source§

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

Source§

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

Source§

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

Source§

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

Implementors§