(makeIter makeIterFn)
| 2546 | } |
| 2547 | |
| 2548 | func createServiceStatsIterator(makeIter makeIterFn) parquetquery.Iterator { |
| 2549 | serviceStatsIters := []parquetquery.Iterator{ |
| 2550 | makeIter(columnPathServiceStatsServiceName, nil, columnPathServiceStatsServiceName), |
| 2551 | makeIter(columnPathServiceStatsSpanCount, nil, columnPathServiceStatsSpanCount), |
| 2552 | makeIter(columnPathServiceStatsErrorCount, nil, columnPathServiceStatsErrorCount), |
| 2553 | } |
| 2554 | return parquetquery.NewJoinIterator(DefinitionLevelServiceStats, serviceStatsIters, &serviceStatsCollector{}) |
| 2555 | } |
| 2556 | |
| 2557 | func createTraceIterator(makeIter makeIterFn, resourceIter parquetquery.Iterator, conds []traceql.Condition, start, end uint64, allConditions bool, selectAll bool, |
| 2558 | sampler traceql.Sampler, |
no test coverage detected