zhjwpku commented on code in PR #238:
URL: https://github.com/apache/iceberg-cpp/pull/238#discussion_r2440566422
##########
src/iceberg/expression/literal.cc:
##########
@@ -331,12 +339,50 @@ std::strong_ordering CompareFloat(T lhs, T rhs) {
return lhs_is_negative <=> rhs_is_negative;
}
+std::partial_ordering CompareDecimal(Literal const& lhs, Literal const& rhs) {
+ ICEBERG_DCHECK(std::holds_alternative<Decimal>(lhs.value()),
+ "LHS of decimal comparison must hold Decimal");
+ ICEBERG_DCHECK(std::holds_alternative<Decimal>(rhs.value()),
+ "RHS of decimal comparison must hold decimal");
+ auto lhs_type = internal::checked_pointer_cast<DecimalType>(lhs.type());
+ auto rhs_type = internal::checked_pointer_cast<DecimalType>(rhs.type());
+ auto lhs_decimal = std::get<Decimal>(lhs.value());
+ auto rhs_decimal = std::get<Decimal>(rhs.value());
+ if (lhs_type->scale() == rhs_type->scale()) {
+ return lhs_decimal <=> rhs_decimal;
+ } else if (lhs_type->scale() > rhs_type->scale()) {
+ // Rescale to larger scale
+ auto rhs_res = rhs_decimal.Rescale(rhs_type->scale(), lhs_type->scale());
+ if (!rhs_res.has_value()) {
+ if (rhs_res.error().kind == ErrorKind::kRescaleDataLoss) {
Review Comment:
I've done this way, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
