async fn advance_shard_upper(
persist_writer: &mut WriteHandle<SourceData, (), Timestamp, Diff>,
upper: Antichain<Timestamp>,
)
Expand description
Advance the frontier of the given writer’s shard to at least the given upper
.
async fn advance_shard_upper(
persist_writer: &mut WriteHandle<SourceData, (), Timestamp, Diff>,
upper: Antichain<Timestamp>,
)
Advance the frontier of the given writer’s shard to at least the given upper
.