(op traceql.Operator, operands traceql.Operands)
| 2042 | } |
| 2043 | |
| 2044 | func createPredicate(op traceql.Operator, operands traceql.Operands) (parquetquery.Predicate, error) { |
| 2045 | if pred, handled := createExistencePredicate(op); handled { |
| 2046 | return pred, nil |
| 2047 | } |
| 2048 | |
| 2049 | switch operands[0].Type { |
| 2050 | case traceql.TypeString, traceql.TypeStringArray: |
| 2051 | return createStringPredicate(op, operands) |
| 2052 | case traceql.TypeInt, traceql.TypeIntArray: |
| 2053 | return createIntPredicate(op, operands) |
| 2054 | case traceql.TypeFloat, traceql.TypeFloatArray: |
| 2055 | return createFloatPredicate(op, operands) |
| 2056 | case traceql.TypeBoolean, traceql.TypeBooleanArray: |
| 2057 | return createBoolPredicate(op, operands) |
| 2058 | default: |
| 2059 | return nil, fmt.Errorf("cannot create predicate for operand: %v", operands[0]) |
| 2060 | } |
| 2061 | } |
| 2062 | |
| 2063 | func createStringPredicate(op traceql.Operator, operands traceql.Operands) (parquetquery.Predicate, error) { |
| 2064 | if pred, handled := createExistencePredicate(op); handled { |
no test coverage detected