Function createFloatPredicate

tempodb/encoding/vparquet4/block_traceql.go:2907–2946

(op traceql.Operator, operands traceql.Operands)

}

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

	switch operands[0].Type {
	case traceql.TypeFloat:
		f := operands[0].Float()

		switch op {
		case traceql.OpEqual:
			return parquetquery.NewFloatEqualPredicate(f), nil
		case traceql.OpNotEqual:
			return parquetquery.NewFloatNotEqualPredicate(f), nil
		case traceql.OpGreater:
			return parquetquery.NewFloatGreaterPredicate(f), nil
		case traceql.OpGreaterEqual:
			return parquetquery.NewFloatGreaterEqualPredicate(f), nil
		case traceql.OpLess:
			return parquetquery.NewFloatLessPredicate(f), nil
		case traceql.OpLessEqual:
			return parquetquery.NewFloatLessEqualPredicate(f), nil
		default:
			return nil, fmt.Errorf("operator not supported for floats: %+v", op)
		}
	case traceql.TypeFloatArray:
		floats, _ := operands[0].FloatArray()

		switch op {
		case traceql.OpEqual, traceql.OpIn:
			return parquetquery.NewFloatInPredicate(floats), nil
		case traceql.OpNotEqual, traceql.OpNotIn:
			return parquetquery.NewFloatNotInPredicate(floats), nil
		default:
			return nil, fmt.Errorf("operator not supported for float arrays: %+v", op)
		}
	default:
		return nil, fmt.Errorf("operand is not float or float array: %s", operands[0].EncodeToString(false))
	}
}

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