Function createStringPredicate

tempodb/encoding/vparquet5/block_traceql.go:2701–2747

(op traceql.Operator, operands traceql.Operands)

}

func createStringPredicate(op traceql.Operator, operands traceql.Operands) (parquetquery.Predicate, error) {
	if pred, handled := createExistencePredicate(op); handled {
		return pred, nil
	}

	switch operands[0].Type {
	case traceql.TypeString:
		s := operands[0].EncodeToString(false)

		switch op {
		case traceql.OpEqual:
			return parquetquery.NewStringEqualPredicate(s), nil
		case traceql.OpNotEqual:
			return parquetquery.NewStringNotEqualPredicate(s), nil
		case traceql.OpRegex:
			return parquetquery.NewRegexInPredicate([]string{s})
		case traceql.OpNotRegex:
			return parquetquery.NewRegexNotInPredicate([]string{s})
		case traceql.OpGreater:
			return parquetquery.NewStringGreaterPredicate([]byte(s)), nil
		case traceql.OpGreaterEqual:
			return parquetquery.NewStringGreaterEqualPredicate([]byte(s)), nil
		case traceql.OpLess:
			return parquetquery.NewStringLessPredicate([]byte(s)), nil
		case traceql.OpLessEqual:
			return parquetquery.NewStringLessEqualPredicate([]byte(s)), nil
		default:
			return nil, fmt.Errorf("operator not supported for strings: %+v", op)
		}
	case traceql.TypeStringArray:
		strs, _ := operands[0].StringArray()
		switch op {
		case traceql.OpEqual, traceql.OpIn:
			return parquetquery.NewStringInPredicate(strs), nil
		case traceql.OpNotEqual, traceql.OpNotIn:
			return parquetquery.NewStringNotInPredicate(strs), nil
		case traceql.OpRegex, traceql.OpRegexMatchAny:
			return parquetquery.NewRegexInPredicate(strs)
		case traceql.OpNotRegex, traceql.OpRegexMatchNone:
			return parquetquery.NewRegexNotInPredicate(strs)
		default:
			return nil, fmt.Errorf("operator not supported for strings arrays: %+v", op)
		}
	default:
		return nil, fmt.Errorf("operand is not a string or string array: %s", operands[0])
	}
}

func createBytesPredicate(op traceql.Operator, operands traceql.Operands, isSpan bool) (parquetquery.Predicate, error) {
	if pred, handled := createExistencePredicate(op); handled {