Method FetchSpans

tempodb/encoding/vparquet5/block_traceql_fetch.go:17–30

(ctx context.Context, req traceql.FetchSpansRequest, opts common.SearchOptions)

)

func (b *backendBlock) FetchSpans(ctx context.Context, req traceql.FetchSpansRequest, opts common.SearchOptions) (traceql.FetchSpansOnlyResponse, error) {
	pf, rr, err := b.openForSearch(ctx, opts)
	if err != nil {
		return traceql.FetchSpansOnlyResponse{}, err
	}
	iter, err := fetchSpans(ctx, req, pf, rowGroupsFromFile(pf, opts), b.meta.DedicatedColumns)
	if err != nil {
		return traceql.FetchSpansOnlyResponse{}, err
	}
	return traceql.FetchSpansOnlyResponse{
		Results: iter,
		Bytes:   func() uint64 { return rr.BytesRead() },
	}, nil
}

// 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) {