Trait mz_compute::render::WithStartSignal

pub(crate) trait WithStartSignal {
    // Required method
    fn with_start_signal(self, signal: StartSignal) -> Self;
}

Extension trait to attach a StartSignal to operator outputs.

Required Methods

fn with_start_signal(self, signal: StartSignal) -> Self

Delays data and progress updates until the start signal has fired.

Note that this operator needs to buffer all incoming data, so it has some memory footprint, depending on the amount and shape of its inputs.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<S, D> WithStartSignal for Stream<S, D>

where S: Scope, D: Data,

fn with_start_signal(self, signal: StartSignal) -> Self

impl<S, Tr> WithStartSignal for Arranged<S, Tr>

where S: Scope, S::Timestamp: RenderTimestamp, Tr: TraceReader + Clone,

fn with_start_signal(self, signal: StartSignal) -> Self

Implementors

impl<S> WithStartSignal for MzArrangementImport<S>

where S: Scope, S::Timestamp: RenderTimestamp,