()
| 229 | } |
| 230 | |
| 231 | func (w *SortedWriter) Abort() { |
| 232 | if w.writer != nil { |
| 233 | w.writer.Abort() |
| 234 | w.writer = nil |
| 235 | } |
| 236 | if w.vectorWriter != nil { |
| 237 | w.vectorWriter.Abort() |
| 238 | w.vectorWriter = nil |
| 239 | } |
| 240 | // Delete all created objects. |
| 241 | for _, o := range w.objects { |
| 242 | o.Remove(w.ctx, w.pool.engine, w.pool.DataPath) |
| 243 | } |
| 244 | } |
| 245 | |
| 246 | func (w *SortedWriter) newWriter() error { |
| 247 | o := data.NewObject() |