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

Method push

src/storage/src/upsert.rs:112–114  ·  view source on GitHub ↗
(&mut self, item: D)

Source from the content-addressed store, hash-verified

110 impl<D, T: columnar::Push<D>> columnar::Push<D> for UpsertKeys<T> {
111 #[inline(always)]
112 fn push(&mut self, item: D) {
113 self.0.push(item)
114 }
115 }
116 impl<T: columnar::Clear> columnar::Clear for UpsertKeys<T> {
117 #[inline(always)]

Callers 15

build_ingestion_dataflowFunction · 0.45
build_export_dataflowFunction · 0.45
upsert_value_to_rowFunction · 0.45
upsert_innerFunction · 0.45
drain_sealed_inputFunction · 0.45
drain_staged_inputFunction · 0.45
run_workerMethod · 0.45
record_new_statusMethod · 0.45
reconcileMethod · 0.45
drop_collectionMethod · 0.45
from_iterMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected