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

Method push

datafusion/datasource/src/morsel/mocks.rs:179–181  ·  view source on GitHub ↗

Records one new scheduler event.

(&self, event: MorselEvent)

Source from the content-addressed store, hash-verified

177
178 /// Records one new scheduler event.
179 pub(crate) fn push(&self, event: MorselEvent) {
180 self.events.lock().unwrap().push(event);
181 }
182
183 /// Formats all recorded events into a stable, snapshot-friendly trace.
184 pub(crate) fn format_events(&self) -> String {

Callers 15

runMethod · 0.45
push_outputMethod · 0.45
with_morselMethod · 0.45
with_morsel_batchesMethod · 0.45
add_planMethod · 0.45
return_noneMethod · 0.45
return_errorMethod · 0.45
plan_fileMethod · 0.45
child_plannersFunction · 0.45
planMethod · 0.45
into_streamMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected