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

Function NewSortedWriter

db/writer.go:182–191  ·  view source on GitHub ↗
(ctx context.Context, sctx *super.Context, pool *Pool, vectorEnabled bool)

Source from the content-addressed store, hash-verified

180}
181
182func NewSortedWriter(ctx context.Context, sctx *super.Context, pool *Pool, vectorEnabled bool) *SortedWriter {
183 return &SortedWriter{
184 comparator: ImportComparator(sctx, pool),
185 ctx: ctx,
186 sctx: sctx,
187 sortKey: pool.SortKeys.Primary(),
188 pool: pool,
189 vectorEnabled: vectorEnabled,
190 }
191}
192
193func (w *SortedWriter) Write(val super.Value) error {
194 key := val.DerefPath(w.sortKey.Key).MissingAsNull()

Callers 1

CompactFunction · 0.92

Calls 2

ImportComparatorFunction · 0.85
PrimaryMethod · 0.80

Tested by

no test coverage detected