Trait mz_compute::render::RenderTimestamp

pub trait RenderTimestamp:
    Timestamp
    + Lattice
    + Refines<Timestamp>
    + Columnation {
    // Required methods
    fn system_time(&mut self) -> &mut Timestamp;
    fn system_delay(delay: Timestamp) -> <Self as Timestamp>::Summary;
    fn event_time(&self) -> Timestamp;
    fn event_time_mut(&mut self) -> &mut Timestamp;
    fn event_delay(delay: Timestamp) -> <Self as Timestamp>::Summary;
    fn step_back(&self) -> Self;
}

A timestamp type that can be used for operations within MZ’s dataflow layer.

Required Methods

fn system_time(&mut self) -> &mut Timestamp

The system timestamp component of the timestamp.

This is useful for manipulating the system time, as when delaying updates for subsequent cancellation, as with monotonic reduction.

fn system_delay(delay: Timestamp) -> <Self as Timestamp>::Summary

Effects a system delay in terms of the timestamp summary.

fn event_time(&self) -> Timestamp

The event timestamp component of the timestamp.

fn event_time_mut(&mut self) -> &mut Timestamp

The event timestamp component of the timestamp, as a mutable reference.

fn event_delay(delay: Timestamp) -> <Self as Timestamp>::Summary

Effects an event delay in terms of the timestamp summary.

fn step_back(&self) -> Self

Steps the timestamp back so that logical compaction to the output will not conflate self with any historical times.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl RenderTimestamp for Timestamp

fn system_time(&mut self) -> &mut Timestamp

fn system_delay(delay: Timestamp) -> <Self as Timestamp>::Summary

fn event_time(&self) -> Timestamp

fn event_time_mut(&mut self) -> &mut Timestamp

fn event_delay(delay: Timestamp) -> <Self as Timestamp>::Summary

fn step_back(&self) -> Self

impl RenderTimestamp for Product<Timestamp, PointStamp<u64>>

fn system_time(&mut self) -> &mut Timestamp

fn system_delay(delay: Timestamp) -> <Self as Timestamp>::Summary

fn event_time(&self) -> Timestamp

fn event_time_mut(&mut self) -> &mut Timestamp

fn event_delay(delay: Timestamp) -> <Self as Timestamp>::Summary

fn step_back(&self) -> Self

Implementors