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

Function batch

datafusion/datasource/src/memory.rs:1006–1011  ·  view source on GitHub ↗
(row_size: usize)

Source from the content-addressed store, hash-verified

1004 }
1005
1006 fn batch(row_size: usize) -> RecordBatch {
1007 let a: ArrayRef = Arc::new(Int32Array::from(vec![1; row_size]));
1008 let b: ArrayRef = Arc::new(StringArray::from_iter(vec![Some("foo"); row_size]));
1009 let c: ArrayRef = Arc::new(Int64Array::from_iter(vec![1; row_size]));
1010 RecordBatch::try_from_iter(vec![("a", a), ("b", b), ("c", c)]).unwrap()
1011 }
1012
1013 fn schema() -> SchemaRef {
1014 batch(1).schema()

Callers 1

schemaFunction · 0.85

Calls 1

newFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…