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

Method flush_in_progress

datafusion/functions/src/strings.rs:843–848  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

841 }
842
843 fn flush_in_progress(&mut self) {
844 if !self.in_progress.is_empty() {
845 let block = std::mem::take(&mut self.in_progress);
846 self.completed.push(Buffer::from_vec(block));
847 }
848 }
849
850 /// Finalize into a [`StringViewArray`] using the caller-supplied null
851 /// buffer.

Callers 3

append_valueMethod · 0.45
ensure_long_capacityMethod · 0.45
finishMethod · 0.45

Calls 2

is_emptyMethod · 0.45
pushMethod · 0.45

Tested by

no test coverage detected