Function createTraceIterators

tempodb/encoding/vparquet5/block_traceql_fetch.go:217–283

(
	makeIter makeIterFn,
	conditions []traceql.Condition,
	start, end uint64,
	allConditions bool,
	_ backend.DedicatedColumns,
	selectAll bool,
)

}

func createTraceIterators(
	makeIter makeIterFn,
	conditions []traceql.Condition,
	start, end uint64,
	allConditions bool,
	_ backend.DedicatedColumns,
	selectAll bool,
) (required, optional []parquetquery.Iterator) {
	var alwaysOptional []parquetquery.Iterator

	for _, cond := range conditions {
		switch cond.Attribute.Intrinsic {
		case traceql.IntrinsicTraceID:
			if cond.Op == traceql.OpNone && cond.CallBack != nil {
				// This is expected to quit early, so it is always optional below.
				alwaysOptional = append(alwaysOptional, makeIter(columnPathTraceID, parquetquery.NewCallbackPredicate(cond.CallBack), columnPathTraceID))
			} else {
				// This starts as optional but can be moved to required for better performance.
				optional = append(optional, makeIter(columnPathTraceID, nil, columnPathTraceID))
			}
		case traceql.IntrinsicTraceDuration:
			optional = append(optional, makeIter(columnPathDurationNanos, nil, columnPathDurationNanos))
		case traceql.IntrinsicTraceStartTime:
			optional = append(optional, makeIter(columnPathStartTimeUnixNano, nil, columnPathStartTimeUnixNano))
		}
	}

	// evaluate time range
	// Time range filtering?
	if start > 0 && end > 0 {
		// Here's how we detect the span overlaps the time window:
		// Span start <= req.End
		// Span end >= req.Start
		var startFilter, endFilter parquetquery.Predicate
		startFilter = parquetquery.NewIntBetweenPredicate(0, int64(end))
		endFilter = parquetquery.NewIntBetweenPredicate(int64(start), math.MaxInt64)

		required = append(required, makeIter(columnPathStartTimeUnixNano, startFilter, columnPathStartTimeUnixNano))
		required = append(required, makeIter(columnPathEndTimeUnixNano, endFilter, columnPathEndTimeUnixNano))
	}

	if selectAll {
		for intrins, entry := range intrinsicColumnLookups {
			if entry.scope != intrinsicScopeTrace {
				continue
			}
			// These intrinsics aren't included in select all because they are not
			// useful for filtering or grouping.
			switch intrins {
			case traceql.IntrinsicTraceStartTime,
				traceql.IntrinsicServiceStats:
				continue
			}
			required = append(required, makeIter(entry.columnPath, nil, entry.columnPath))
		}
	}

	// If all conditions move them to required