Slice the record batch into 2 batches
(batch: &RecordBatch)
| 669 | |
| 670 | /// Slice the record batch into 2 batches |
| 671 | fn split_batch(batch: &RecordBatch) -> Vec<RecordBatch> { |
| 672 | assert!(batch.num_rows() > 1); |
| 673 | let split = batch.num_rows() / 2; |
| 674 | vec![ |
| 675 | batch.slice(0, split), |
| 676 | batch.slice(split, batch.num_rows() - split), |
| 677 | ] |
| 678 | } |
| 679 | } |
no outgoing calls
searching dependent graphs…