Skip to content

Commit 78f0159

Browse files
Subham SinghalSubham Singhal
authored andcommitted
Adds decimal32 and 64 types
1 parent e4232d4 commit 78f0159

1 file changed

Lines changed: 16 additions & 0 deletions

File tree

datafusion/spark/src/function/math/negative.rs

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -188,6 +188,22 @@ fn spark_negative(args: &[ColumnarValue]) -> Result<ColumnarValue> {
188188
}
189189

190190
// Decimal types - wrapping negation
191+
ScalarValue::Decimal32(Some(v), precision, scale) => {
192+
let result = v.wrapping_neg();
193+
Ok(ColumnarValue::Scalar(ScalarValue::Decimal32(
194+
Some(result),
195+
*precision,
196+
*scale,
197+
)))
198+
}
199+
ScalarValue::Decimal64(Some(v), precision, scale) => {
200+
let result = v.wrapping_neg();
201+
Ok(ColumnarValue::Scalar(ScalarValue::Decimal64(
202+
Some(result),
203+
*precision,
204+
*scale,
205+
)))
206+
}
191207
ScalarValue::Decimal128(Some(v), precision, scale) => {
192208
let result = v.wrapping_neg();
193209
Ok(ColumnarValue::Scalar(ScalarValue::Decimal128(

0 commit comments

Comments
 (0)