Struct mz_compute::logging::compute::CollectionLogging

pub struct CollectionLogging {
    id: GlobalId,
    logger: Logger<ComputeEvent, WorkerIdentifier>,
    logged_frontier: Option<Timestamp>,
    logged_import_frontiers: BTreeMap<GlobalId, Timestamp>,
}

Logging state maintained for a compute collection.

This type is used to produce appropriate log events in response to changes of logged collection state, e.g. frontiers, and to produce cleanup events when a collection is dropped.

Fields

id: GlobalId

logger: Logger<ComputeEvent, WorkerIdentifier>

logged_frontier: Option<Timestamp>

logged_import_frontiers: BTreeMap<GlobalId, Timestamp>

Implementations

impl CollectionLogging

pub fn new( id: GlobalId, logger: Logger<ComputeEvent, WorkerIdentifier>, dataflow_index: usize, import_ids: impl Iterator<Item = GlobalId>, ) -> Self

Create new logging state for the identified collection and emit initial logging events.

pub fn set_frontier(&mut self, new_time: Option<Timestamp>)

Set the collection frontier to the given new time and emit corresponding logging events.

pub fn set_import_frontier( &mut self, import_id: GlobalId, new_time: Option<Timestamp>, )

Set the frontier of the given import to the given new time and emit corresponding logging events.

pub fn set_hydrated(&self)

Set the collection as hydrated.

Trait Implementations

impl Drop for CollectionLogging

fn drop(&mut self)

Executes the destructor for this type.