(op traceql.Operator, operands traceql.Operands)
| 2680 | } |
| 2681 | |
| 2682 | func createPredicate(op traceql.Operator, operands traceql.Operands) (parquetquery.Predicate, error) { |
| 2683 | if pred, handled := createExistencePredicate(op); handled { |
| 2684 | return pred, nil |
| 2685 | } |
| 2686 | |
| 2687 | switch operands[0].Type { |
| 2688 | case traceql.TypeString, traceql.TypeStringArray: |
| 2689 | return createStringPredicate(op, operands) |
| 2690 | case traceql.TypeInt, traceql.TypeIntArray: |
| 2691 | return createIntPredicate(op, operands) |
| 2692 | case traceql.TypeFloat, traceql.TypeFloatArray: |
| 2693 | return createFloatPredicate(op, operands) |
| 2694 | case traceql.TypeBoolean, traceql.TypeBooleanArray: |
| 2695 | return createBoolPredicate(op, operands) |
| 2696 | default: |
| 2697 | return nil, fmt.Errorf("cannot create predicate for operand: %v", operands[0]) |
| 2698 | } |
| 2699 | } |
| 2700 | |
| 2701 | func createStringPredicate(op traceql.Operator, operands traceql.Operands) (parquetquery.Predicate, error) { |
| 2702 | if pred, handled := createExistencePredicate(op); handled { |
no test coverage detected