(ids: Vec<i32>, values: Vec<i32>)
| 776 | } |
| 777 | |
| 778 | fn make_batch(ids: Vec<i32>, values: Vec<i32>) -> RecordBatch { |
| 779 | let schema = Arc::new(ArrowSchema::new(vec![ |
| 780 | ArrowField::new("id", ArrowDataType::Int32, false), |
| 781 | ArrowField::new("value", ArrowDataType::Int32, false), |
| 782 | ])); |
| 783 | RecordBatch::try_new( |
| 784 | schema, |
| 785 | vec![ |
| 786 | Arc::new(Int32Array::from(ids)), |
| 787 | Arc::new(Int32Array::from(values)), |
| 788 | ], |
| 789 | ) |
| 790 | .unwrap() |
| 791 | } |
| 792 | |
| 793 | fn make_partitioned_batch(pts: Vec<&str>, ids: Vec<i32>) -> RecordBatch { |
| 794 | let schema = Arc::new(ArrowSchema::new(vec![ |
no outgoing calls