mz_storage::upsert

Function rehydration_finished

Source
pub fn rehydration_finished<G, T>(
    scope: G,
    source_config: &RawSourceCreationConfig,
    token: impl Any + 'static,
    resume_upper: Antichain<T>,
    input: &Stream<G, Infallible>,
)
where G: Scope<Timestamp = T>, T: Timestamp,
Expand description

This leaf operator drops token after the input reaches the resume_upper. This is useful to take coordinated actions across all workers, after the upsert operator has rehydrated.