MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / append

Method append

src/storage-controller/src/persist_handles.rs:241–259  ·  view source on GitHub ↗
(
        &self,
        write_ts: Timestamp,
        advance_to: Timestamp,
        updates: Vec<(GlobalId, Vec<TableData>)>,
    )

Source from the content-addressed store, hash-verified

239 }
240
241 pub(crate) fn append(
242 &self,
243 write_ts: Timestamp,
244 advance_to: Timestamp,
245 updates: Vec<(GlobalId, Vec<TableData>)>,
246 ) -> tokio::sync::oneshot::Receiver<Result<(), StorageError>> {
247 let (tx, rx) = tokio::sync::oneshot::channel();
248 // Always send the append command to the txn-wal layer, even for empty
249 // updates. The txn-wal commit advances the logical upper of ALL
250 // registered data shards, which is needed for periodic group commits
251 // that have no actual data writes.
252 self.send(PersistTableWriteCmd::Append {
253 write_ts,
254 advance_to,
255 updates,
256 tx,
257 });
258 rx
259 }
260
261 /// Drops the handles associated with `ids` from this worker.
262 ///

Callers 3

append_tableMethod · 0.45
sync_to_persistMethod · 0.45
runMethod · 0.45

Calls 15

channelFunction · 0.85
SourceDataClass · 0.85
takeFunction · 0.85
compact_toMethod · 0.80
sendMethod · 0.45
beginMethod · 0.45
getMethod · 0.45
writeMethod · 0.45
into_innerMethod · 0.45
write_batchMethod · 0.45
tidyMethod · 0.45
commit_atMethod · 0.45

Tested by

no test coverage detected