Function fetchSpans

tempodb/encoding/vparquet5/block_traceql_fetch.go:33–47

fetchSpans is the core logic for span-only fetch, like fetch is for Fetch. Callers open the parquet file and pass row groups.

(ctx context.Context, req traceql.FetchSpansRequest, pf *parquet.File, rowGroups []parquet.RowGroup, dc backend.DedicatedColumns)

// fetchSpans is the core logic for span-only fetch, like fetch is for Fetch. Callers open the parquet file and pass row groups.
func fetchSpans(ctx context.Context, req traceql.FetchSpansRequest, pf *parquet.File, rowGroups []parquet.RowGroup, dc backend.DedicatedColumns) (*spanOnlyIterator, error) {
	makeIter := makeIterFunc(ctx, rowGroups, pf)
	makeNilIter := makeNilIterFunc(ctx, rowGroups, pf)
	iter, span, err := create(makeIter, makeNilIter, nil, req.Conditions, req.SecondPass, req.StartTimeUnixNanos, req.EndTimeUnixNanos, req.AllConditions, false, dc, req.SpanSampler)
	if err != nil {
		return nil, err
	}
	if len(req.SecondPassConditions) > 0 || req.SecondPassSelectAll {
		iter, span, err = create(makeIter, makeNilIter, iter, req.SecondPassConditions, nil, 0, 0, false, req.SecondPassSelectAll, dc, nil)
		if err != nil {
			return nil, err
		}
	}
	return &spanOnlyIterator{iter: iter, span: span}, nil
}

type spanOnlyIterator struct {
	iter parquetquery.Iterator