(makeIter makeIterFn)
| 2465 | } |
| 2466 | |
| 2467 | func createServiceStatsIterator(makeIter makeIterFn) parquetquery.Iterator { |
| 2468 | serviceStatsIters := []parquetquery.Iterator{ |
| 2469 | makeIter(columnPathServiceStatsServiceName, nil, columnPathServiceStatsServiceName), |
| 2470 | makeIter(columnPathServiceStatsSpanCount, nil, columnPathServiceStatsSpanCount), |
| 2471 | makeIter(columnPathServiceStatsErrorCount, nil, columnPathServiceStatsErrorCount), |
| 2472 | } |
| 2473 | return parquetquery.NewJoinIterator(DefinitionLevelServiceStats, serviceStatsIters, &serviceStatsCollector{}) |
| 2474 | } |
| 2475 | |
| 2476 | func createTraceIterator(makeIter makeIterFn, resourceIter parquetquery.Iterator, conds []traceql.Condition, start, end uint64, allConditions bool, selectAll bool, |
| 2477 | sampler traceql.Sampler, |
no test coverage detected