(row_size: usize)
| 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() |