Method Write

db/writer.go:193–229

(val super.Value)

}

func (w *SortedWriter) Write(val super.Value) error {
	key := val.DerefPath(w.sortKey.Key).MissingAsNull()
again:
	if w.writer == nil {
		if err := w.newWriter(); err != nil {
			w.Abort()
			return err
		}
	}
	if w.writer.BytesWritten() >= w.pool.Threshold &&
		w.comparator.Compare(w.lastKey, key) != 0 {
		if err := w.Close(); err != nil {
			w.Abort()
			return err
		}
		w.writer, w.vectorWriter = nil, nil
		goto again
	}
	if err := w.writer.WriteWithKey(key, val); err != nil {
		w.Abort()
		return err
	}

	if w.vectorWriter != nil {
		// XXX TBD: this is slow and creates a vector per value when writing vectors
		// to a database.  This will change when we convert the database from
		// mixed BSUP/CSUP to CSUP only.
		builder := vector.NewBuilder(val.Type())
		builder.Write(val.Bytes())
		if err := w.vectorWriter.Push(builder.Build(w.sctx)); err != nil {
			w.Abort()
			return err
		}
	}
	w.lastKey.CopyFrom(key)
	return nil
}

func (w *SortedWriter) Abort() {
	if w.writer != nil {