Trait LogDataflowErrors 

pub(crate) trait LogDataflowErrors {
    // Required method
    fn log_dataflow_errors(
        self,
        logger: Logger<ColumnBuilder<(Duration, ComputeEvent)>>,
        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<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".

Implementations on Foreign Types

impl<'scope, T, B> LogDataflowErrors for StreamVec<'scope, T, B>

where T: Timestamp, for<'a> B: BatchReader<DiffGat<'a> = &'a Diff> + Clone + 'static,

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

impl<'scope, T, D> LogDataflowErrors for VecCollection<'scope, T, D, Diff>

where T: Timestamp, D: Clone + 'static,

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

Implementors