(sc *arrow.Schema, rec arrow.RecordBatch)
| 85 | } |
| 86 | |
| 87 | func reverseTransformRecord(sc *arrow.Schema, rec arrow.RecordBatch) arrow.RecordBatch { |
| 88 | cols := make([]arrow.Array, rec.NumCols()) |
| 89 | |
| 90 | for i := 0; i < int(rec.NumCols()); i++ { |
| 91 | cols[i] = reverseTransformArray(sc.Field(i).Type, rec.Column(i)) |
| 92 | } |
| 93 | |
| 94 | return array.NewRecordBatch(sc, cols, rec.NumRows()) |
| 95 | } |
| 96 | |
| 97 | func reverseTransformArray(dt arrow.DataType, arr arrow.Array) arrow.Array { |
| 98 | if arrow.TypeEqual(dt, arr.DataType()) { |
no test coverage detected