Trait mz_compute::logging::compute::LogImportFrontiers

pub(crate) trait LogImportFrontiers {
    // Required method
    fn log_import_frontiers(
        self,
        logger: Logger<ComputeEvent, WorkerIdentifier>,
        import_id: GlobalId,
        export_ids: Vec<GlobalId>
    ) -> Self;
}

Extension trait to attach ComputeEvent::ImportFrontier logging operators to streams and arrangements.

Required Methods

fn log_import_frontiers( self, logger: Logger<ComputeEvent, WorkerIdentifier>, import_id: GlobalId, export_ids: Vec<GlobalId> ) -> Self

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<G, C> LogImportFrontiers for StreamCore<G, C>where G: Scope<Timestamp = Timestamp>, C: Container,

fn log_import_frontiers( self, logger: Logger<ComputeEvent, WorkerIdentifier>, import_id: GlobalId, export_ids: Vec<GlobalId> ) -> Self

impl<G, Tr> LogImportFrontiers for Arranged<G, Tr>where G: Scope<Timestamp = Timestamp>, Tr: TraceReader + Clone,

fn log_import_frontiers( self, logger: Logger<ComputeEvent, WorkerIdentifier>, import_id: GlobalId, export_ids: Vec<GlobalId> ) -> Self

Implementors