(vec vector.Any)
| 24 | } |
| 25 | |
| 26 | func (f *FloatEncoder) Write(vec vector.Any) { |
| 27 | if vec.Len() == 0 { |
| 28 | return |
| 29 | } |
| 30 | fv := vec.(*vector.Float) |
| 31 | if len(f.vals) == 0 { |
| 32 | f.min = fv.Values[0] |
| 33 | f.max = fv.Values[0] |
| 34 | } |
| 35 | for _, v := range fv.Values { |
| 36 | if v < f.min { |
| 37 | f.min = v |
| 38 | } |
| 39 | if v > f.max { |
| 40 | f.max = v |
| 41 | } |
| 42 | } |
| 43 | f.vals = append(f.vals, fv.Values...) |
| 44 | } |
| 45 | |
| 46 | func (f *FloatEncoder) Encode(group *errgroup.Group) { |
| 47 | group.Go(func() error { |