Skip to content

Commit 2d04ad0

Browse files
committed
This commit includes:
1. For null value for FLOAT column, use NaN as transformation value
1 parent c5514f6 commit 2d04ad0

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

pinot-core/src/main/java/org/apache/pinot/core/operator/transform/function/RoundDecimalTransformFunction.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,8 +90,12 @@ public double[] transformToDoubleValuesSV(ValueBlock valueBlock) {
9090
double[] leftValues = _leftTransformFunction.transformToDoubleValuesSV(valueBlock);
9191
if (_fixedScale) {
9292
for (int i = 0; i < length; i++) {
93-
_doubleValuesSV[i] = BigDecimal.valueOf(leftValues[i])
94-
.setScale(_scale, RoundingMode.HALF_UP).doubleValue();
93+
if (Double.NEGATIVE_INFINITY == leftValues[i]) {
94+
_doubleValuesSV[i] = Double.NaN;
95+
} else {
96+
_doubleValuesSV[i] = BigDecimal.valueOf(leftValues[i])
97+
.setScale(_scale, RoundingMode.HALF_UP).doubleValue();
98+
}
9599
}
96100
} else if (_rightTransformFunction != null) {
97101
int[] rightValues = _rightTransformFunction.transformToIntValuesSV(valueBlock);

0 commit comments

Comments
 (0)