Function mz_compute::render::continual_task::truncating_compare_and_append
source ยท async fn truncating_compare_and_append(
write_handle: &mut WriteHandle<SourceData, (), Timestamp, Diff>,
to_append: Vec<((&SourceData, &()), &Timestamp, &Diff)>,
new_upper: Antichain<Timestamp>,
) -> Antichain<Timestamp>
Expand description
Writes the given data to the shard, truncating it as necessary.
Returns the latest known upper for the shard.