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

Function new_exec_with_batches

datafusion/datasource/src/memory.rs:927–932  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

925
926 #[test]
927 fn new_exec_with_batches() {
928 let batch = make_partition(7);
929 let schema = batch.schema();
930 let batches = vec![batch.clone(), batch];
931 let _exec = MemorySourceConfig::try_new_from_batches(schema, batches).unwrap();
932 }
933
934 #[test]
935 fn new_exec_with_batches_empty() {

Callers

nothing calls this directly

Calls 2

make_partitionFunction · 0.70
schemaMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…