()
| 244 | } |
| 245 | |
| 246 | func (w *SortedWriter) newWriter() error { |
| 247 | o := data.NewObject() |
| 248 | var err error |
| 249 | w.writer, err = o.NewWriter(w.ctx, w.pool.engine, w.pool.DataPath, w.sortKey, w.pool.SeekStride) |
| 250 | if err != nil { |
| 251 | return err |
| 252 | } |
| 253 | if w.vectorEnabled { |
| 254 | w.vectorWriter, err = o.NewVectorWriter(w.ctx, w.pool.engine, w.pool.DataPath) |
| 255 | if err != nil { |
| 256 | return err |
| 257 | } |
| 258 | } |
| 259 | w.objects = append(w.objects, &o) |
| 260 | return nil |
| 261 | } |
| 262 | |
| 263 | func (w *SortedWriter) Objects() []*data.Object { |
| 264 | return w.objects |
no test coverage detected