(vec vector.Any)
| 26 | } |
| 27 | |
| 28 | func (a *ArrayEncoder) Write(vec vector.Any) { |
| 29 | if vec.Len() == 0 { |
| 30 | return |
| 31 | } |
| 32 | switch vec := vec.(type) { |
| 33 | case *vector.Array: |
| 34 | a.count += vec.Len() |
| 35 | a.values.Write(vec.Values) |
| 36 | a.offsets.write(vec.Offsets) |
| 37 | case *vector.Set: |
| 38 | a.count += vec.Len() |
| 39 | a.values.Write(vec.Values) |
| 40 | a.offsets.write(vec.Offsets) |
| 41 | default: |
| 42 | panic(vec) |
| 43 | } |
| 44 | } |
| 45 | |
| 46 | func (a *ArrayEncoder) Encode(group *errgroup.Group) { |
| 47 | a.offsets.Encode(group) |