(vec vector.Any)
| 105 | } |
| 106 | |
| 107 | func (u *UintEncoder) Write(vec vector.Any) { |
| 108 | if vec.Len() == 0 { |
| 109 | return |
| 110 | } |
| 111 | uv := vec.(*vector.Uint) |
| 112 | if len(u.vals) == 0 { |
| 113 | u.min = uv.Values[0] |
| 114 | u.max = uv.Values[0] |
| 115 | } |
| 116 | for _, v := range uv.Values { |
| 117 | if v < u.min { |
| 118 | u.min = v |
| 119 | } |
| 120 | if v > u.max { |
| 121 | u.max = v |
| 122 | } |
| 123 | } |
| 124 | u.vals = append(u.vals, uv.Values...) |
| 125 | } |
| 126 | |
| 127 | func (u *UintEncoder) Encode(group *errgroup.Group) { |
| 128 | group.Go(func() error { |