(vec vector.Any)
| 29 | } |
| 30 | |
| 31 | func (u *UnionEncoder) Write(vec vector.Any) { |
| 32 | if vec.Len() == 0 { |
| 33 | return |
| 34 | } |
| 35 | union := vec.(*vector.Union) |
| 36 | u.count += vec.Len() |
| 37 | u.tags.Append(union.Tags) |
| 38 | for tag := range u.values { |
| 39 | u.values[tag].Write(union.Values[tag]) |
| 40 | } |
| 41 | } |
| 42 | |
| 43 | func (u *UnionEncoder) Emit(w io.Writer) error { |
| 44 | if err := u.tags.Emit(w); err != nil { |