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

Method write_batch

src/txn-wal/src/txn_write.rs:101–103  ·  view source on GitHub ↗

Stage a [`Batch`] to the in-progress txn. The timestamp will be assigned at commit time.

(&mut self, data_id: &ShardId, batch: ProtoBatch)

Source from the content-addressed store, hash-verified

99 ///
100 /// The timestamp will be assigned at commit time.
101 pub fn write_batch(&mut self, data_id: &ShardId, batch: ProtoBatch) {
102 self.writes.entry(*data_id).or_default().staged.push(batch)
103 }
104
105 /// Commit this transaction at `commit_ts`.
106 ///

Callers 2

appendMethod · 0.45
run_destination_commandFunction · 0.45

Calls 2

pushMethod · 0.45
entryMethod · 0.45

Tested by

no test coverage detected