Function mz_storage::render::upsert::upsert

pub(crate) fn upsert<G: Scope, O: ExchangeData + Ord>(
    input: &Collection<G, (UpsertKey, Option<Result<Row, UpsertError>>, O), Diff>,
    upsert_envelope: UpsertEnvelope,
    resume_upper: Antichain<G::Timestamp>,
    previous: Collection<G, Result<Row, DataflowError>, Diff>,
    previous_token: Option<Vec<PressOnDropButton>>,
    source_config: RawSourceCreationConfig,
    instance_context: &StorageInstanceContext,
    storage_configuration: &StorageConfiguration,
    dataflow_paramters: &DataflowParameters,
    backpressure_metrics: Option<BackpressureMetrics>
) -> (Collection<G, Result<Row, DataflowError>, Diff>, Stream<G, (usize, HealthStatusUpdate)>, PressOnDropButton)where
    G::Timestamp: TotalOrder,

Resumes an upsert computation at resume_upper given as inputs a collection of upsert commands and the collection of the previous output of this operator. Returns a tuple of

• A collection of the computed upsert operator and,
• A health update stream to propagate errors