MCPcopy Create free account
hub / github.com/brimdata/super / writeIndex

Method writeIndex

db/data/writer.go:74–90  ·  view source on GitHub ↗
(key super.Value)

Source from the content-addressed store, hash-verified

72}
73
74func (w *Writer) writeIndex(key super.Value) error {
75 w.seekIndexTrigger += len(key.Bytes())
76 if w.first {
77 w.first = false
78 w.object.Min.CopyFrom(key)
79 }
80 if w.seekMin == nil {
81 w.seekMin = key.Copy().Ptr()
82 }
83 if w.seekIndexTrigger < w.seekIndexStride {
84 return nil
85 }
86 if err := w.writer.EndStream(); err != nil {
87 return err
88 }
89 return w.flushSeekIndex()
90}
91
92func (w *Writer) flushSeekIndex() error {
93 if w.seekMin != nil {

Callers 1

WriteWithKeyMethod · 0.95

Calls 6

flushSeekIndexMethod · 0.95
CopyFromMethod · 0.80
PtrMethod · 0.80
EndStreamMethod · 0.80
BytesMethod · 0.45
CopyMethod · 0.45

Tested by

no test coverage detected