Method Iterator

tempodb/encoding/vparquet4/wal_block.go:475–515

(ctx context.Context)

}

func (b *walBlock) Iterator(ctx context.Context) (common.Iterator, error) {
	flushed := b.readFlushes()
	bookmarks := make([]*bookmark[parquet.Row], 0, len(flushed))

	for _, page := range flushed {
		iter, err := page.rowIterator(ctx)
		if err != nil {
			return nil, fmt.Errorf("error creating iterator for %s: %w", page.path, err)
		}
		bookmarks = append(bookmarks, newBookmark[parquet.Row](iter))
	}

	sch := parquet.SchemaOf(new(Trace))
	iter := newMultiblockIterator(bookmarks, func(rows []parquet.Row) (parquet.Row, error) {
		if len(rows) == 1 {
			return rows[0], nil
		}

		ts := make([]*Trace, 0, len(rows))
		for _, row := range rows {
			tr := &Trace{}
			err := sch.Reconstruct(tr, row)
			if err != nil {
				return nil, err
			}
			ts = append(ts, tr)
			completeBlockRowPool.Put(row)
		}

		// TODO: walBlock.Iterator is called when creating a complete block from a wal block. it would be
		// nice to track trace disconnectd metrics while doing this. unfortunately there is no clean way for this
		// code to know that it's being called in that context. perhaps find a way to do this in the future
		t := combineTraces(ts...)
		row := completeBlockRowPool.Get()
		row = sch.Deconstruct(row, t)

		return row, nil
	})

	return newCommonIterator(b.meta, iter, sch), nil
}

func (b *walBlock) Clear() error {
	var errs multierror.MultiError