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

Method insert

src/compute/src/sink/correction.rs:78–83  ·  view source on GitHub ↗

Insert a batch of updates.

(&mut self, updates: &mut Vec<(D, Timestamp, Diff)>)

Source from the content-addressed store, hash-verified

76
77 /// Insert a batch of updates.
78 pub fn insert(&mut self, updates: &mut Vec<(D, Timestamp, Diff)>) {
79 match self {
80 Self::V1(c) => c.insert(updates),
81 Self::V2(c) => c.insert(updates),
82 }
83 }
84
85 /// Insert a batch of updates, after negating their diffs.
86 pub fn insert_negated(&mut self, updates: &mut Vec<(D, Timestamp, Diff)>) {

Callers 15

depends_on_intoMethod · 0.45
export_ids_forFunction · 0.45
check_invariantsMethod · 0.45
import_indexMethod · 0.45
import_sourceMethod · 0.45
export_indexMethod · 0.45
export_sinkMethod · 0.45
depends_on_intoMethod · 0.45
lowerMethod · 0.45
buildMethod · 0.45
newMethod · 0.45

Calls 2

clearMethod · 0.45
insert_innerMethod · 0.45