| 136 | } |
| 137 | |
| 138 | func (c *Client) reverseTransformer(table *schema.Table, values bson.M) (arrow.RecordBatch, error) { |
| 139 | sc := table.ToArrowSchema() |
| 140 | bldr := array.NewRecordBuilder(memory.DefaultAllocator, sc) |
| 141 | for i, f := range sc.Fields() { |
| 142 | if err := c.reverseTransform(f, bldr.Field(i), values[sc.Field(i).Name]); err != nil { |
| 143 | return nil, err |
| 144 | } |
| 145 | } |
| 146 | rec := bldr.NewRecordBatch() |
| 147 | return rec, nil |
| 148 | } |
| 149 | |
| 150 | func (c *Client) Read(ctx context.Context, table *schema.Table, res chan<- arrow.RecordBatch) error { |
| 151 | tableName := table.Name |