Trait mz_compute::render::RenderTimestamp

source ·
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;
}
Expand description

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

Required Methods§

source

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.

source

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

Effects a system delay in terms of the timestamp summary.

source

fn event_time(&self) -> Timestamp

The event timestamp component of the timestamp.

source

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

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

source

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

Effects an event delay in terms of the timestamp summary.

source

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§

source§

impl RenderTimestamp for Timestamp

source§

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

source§

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

source§

fn event_time(&self) -> Timestamp

source§

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

source§

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

source§

fn step_back(&self) -> Self

source§

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

source§

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

source§

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

source§

fn event_time(&self) -> Timestamp

source§

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

source§

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

source§

fn step_back(&self) -> Self

Implementors§