(r arrow.RecordBatch)
| 77 | } |
| 78 | |
| 79 | func slice(r arrow.RecordBatch) []arrow.RecordBatch { |
| 80 | res := make([]arrow.RecordBatch, r.NumRows()) |
| 81 | for i := int64(0); i < r.NumRows(); i++ { |
| 82 | res[i] = r.NewSlice(i, i+1) |
| 83 | } |
| 84 | return res |
| 85 | } |
| 86 | |
| 87 | func reverseTransformRecord(sc *arrow.Schema, rec arrow.RecordBatch) arrow.RecordBatch { |
| 88 | cols := make([]arrow.Array, rec.NumCols()) |