MCPcopy Create free account
hub / github.com/apache/datafusion / update

Method update

datafusion/physical-plan/src/work_table.rs:84–86  ·  view source on GitHub ↗

Update the results of a recursive query iteration to the work table.

(&self, batches: ReservedBatches)

Source from the content-addressed store, hash-verified

82
83 /// Update the results of a recursive query iteration to the work table.
84 pub(super) fn update(&self, batches: ReservedBatches) {
85 self.batches.lock().unwrap().replace(batches);
86 }
87}
88
89/// A temporary "working table" operation where the input data will be

Calls

no outgoing calls