(op traceql.Operator, operands traceql.Operands)
| 2599 | } |
| 2600 | |
| 2601 | func createPredicate(op traceql.Operator, operands traceql.Operands) (parquetquery.Predicate, error) { |
| 2602 | if pred, handled := createExistencePredicate(op); handled { |
| 2603 | return pred, nil |
| 2604 | } |
| 2605 | |
| 2606 | switch operands[0].Type { |
| 2607 | case traceql.TypeString, traceql.TypeStringArray: |
| 2608 | return createStringPredicate(op, operands) |
| 2609 | case traceql.TypeInt, traceql.TypeIntArray: |
| 2610 | return createIntPredicate(op, operands) |
| 2611 | case traceql.TypeFloat, traceql.TypeFloatArray: |
| 2612 | return createFloatPredicate(op, operands) |
| 2613 | case traceql.TypeBoolean, traceql.TypeBooleanArray: |
| 2614 | return createBoolPredicate(op, operands) |
| 2615 | default: |
| 2616 | return nil, fmt.Errorf("cannot create predicate for operand: %v", operands[0]) |
| 2617 | } |
| 2618 | } |
| 2619 | |
| 2620 | func createStringPredicate(op traceql.Operator, operands traceql.Operands) (parquetquery.Predicate, error) { |
| 2621 | if pred, handled := createExistencePredicate(op); handled { |
no test coverage detected